Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

enhancement(kubernetes_logs source): Wire up acknowledgement support via existing file ack support #22366

Open
wants to merge 3 commits into
base: master
Choose a base branch
from

Conversation

ganelo
Copy link
Contributor

@ganelo ganelo commented Feb 4, 2025

Summary

Mirror changes made to file source as part of implementing acknowledgements support there over to kubernetes_logs source.

Change Type

  • Bug fix
  • New feature
  • Non-functional (chore, refactoring, docs)
  • Performance

Is this a breaking change?

  • Yes
  • No

How did you test this PR?

Given that the underlying feature work for implementing acknowledgements in the file source is well-tested, my plan is to deploy a custom build of vector with this change to a dev environment and simply smoke test to confirm that, when acknowledgements are enabled via config, we see evidence that log events are not considered processed until they are fully delivered at the end of the sink chain (eg by counting unique log event ids at the end of the test after bouncing some of the intermediate hops in chain during the test).

Does this PR include user facing changes?

  • Yes. Please add a changelog fragment based on our guidelines.
  • No. A maintainer will apply the "no-changelog" label to this PR.

Checklist

  • Please read our Vector contributor resources.
    • make check-all is a good command to run locally. This check is
      defined here. Some of these
      checks might not be relevant to your PR. For Rust changes, at the very least you should run:
      • cargo fmt --all
      • cargo clippy --workspace --all-targets -- -D warnings
      • cargo nextest run --workspace (alternatively, you can run cargo test --all)
  • If this PR introduces changes Vector dependencies (modifies Cargo.lock), please
    run dd-rust-license-tool write to regenerate the license inventory and commit the changes (if any). More details here.

References

@ganelo ganelo requested a review from a team as a code owner February 4, 2025 20:21
@github-actions github-actions bot added the domain: sources Anything related to the Vector's sources label Feb 4, 2025
@pront
Copy link
Member

pront commented Feb 6, 2025

Hi @ganelo and thank you for this PR. The make check-component-docs check failed. Can you take a look?

@ganelo ganelo force-pushed the og/kubernetes_logs_ack_support branch from 6cb511b to ed6c692 Compare February 6, 2025 22:18
@ganelo
Copy link
Contributor Author

ganelo commented Feb 6, 2025

Hi @ganelo and thank you for this PR. The make check-component-docs check failed. Can you take a look?

Hi @pront - this seems to be broken on master, as far as I can tell. In any case, nothing I've touched should have broken the ruby script. Not sure how best to proceed.

@jszwedko
Copy link
Member

jszwedko commented Feb 6, 2025

Hi @ganelo and thank you for this PR. The make check-component-docs check failed. Can you take a look?

Hi @pront - this seems to be broken on master, as far as I can tell. In any case, nothing I've touched should have broken the ruby script. Not sure how best to proceed.

Can you share the failure? The script requires Ruby 3, which often trips people up.

@pront
Copy link
Member

pront commented Feb 6, 2025

Hi @pront - this seems to be broken on master, as far as I can tell.

I verified that it is not broken master.

In any case, nothing I've touched should have broken the ruby script. Not sure how best to proceed.

This PR adds configuration fields and we rely on source code to generate docs. Hence, docs need to regenerated. As @jszwedko pointed out we have a dependency on Ruby 3. My version locally:

❯ ruby -v
ruby 3.1.4p223 (2023-03-30 revision 957bb7cb81) [arm64-darwin22]

@ganelo
Copy link
Contributor Author

ganelo commented Feb 7, 2025 via email

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
domain: sources Anything related to the Vector's sources
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Add support for end-to-end acknowledgements to kubernetes_logs source
4 participants