-
Notifications
You must be signed in to change notification settings - Fork 1.6k
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
fix(kafka sink): retry messages that result in kafka policy violations #22041
base: master
Are you sure you want to change the base?
fix(kafka sink): retry messages that result in kafka policy violations #22041
Conversation
3fb7bb2
to
3eaeee3
Compare
Problem: Some messages were getting dropped by Vector due to Kafka throwing `PolicyViolation` errors. These should be retried as a policy can be as simple as a more aggressive rate limit. ---------- Solution: Retry any messages that had the `RDKafkaErrorCode::PolicyViolation` error. ---------- Note: A dynamic back off may be better, as there may be a rate limit out there that still needs more than 100ms to back off on requests. ---------- See the original issue at vectordotdev#22026 Closes vectordotdev#22026
296551f
to
3bfca14
Compare
Realized I did not need to include that changelog entry for this PR. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Actually could we add a changelog entry here describing the fix for users? See https://github.com/vectordotdev/vector/blob/master/changelog.d/README.md
3bfca14
to
296551f
Compare
Reincluded the changelog entry. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @PriceHiller !
Summary
Copied from the body of the commit:
Ensures Kafka retries messages that error out with
RDKafkaErrorCode::PolicyViolation
.Change Type
Is this a breaking change?
How did you test this PR?
cargo test --no-default-features --features "sinks-console,sinks-kafka,kafka-integration-tests" -- --skip 'sinks::kafka::tests::integration_test' 'sinks::kafka'
make test-integration-kafka
Has to do with
sources::kafka::integration_test::drains_acknowledgements_during_rebalance_default_assignments
Does this PR include user facing changes?
Checklist
Cargo.lock
), pleaserun
dd-rust-license-tool write
to regenerate the license inventory and commit the changes (if any). More details here.References