[otap-dataflow] Kafka shared test helper#3563
Open
c1ly wants to merge 4 commits into
Open
Conversation
github-actions
Bot
added
area:pipeline
Pull request dashboard statusStatus last refreshed: 2026-07-25 22:03:01 UTC.
This automated status or its linked feedback items may be incorrect. If something looks wrong, please report it with the result you expected. |
Codecov Report❌ Patch coverage is ❌ Your patch check has failed because the patch coverage (70.37%) is below the target coverage (80.00%). You can increase the patch coverage or adjust the target coverage. Additional details and impacted files@@ Coverage Diff @@
## main #3563 +/- ##
==========================================
- Coverage 86.88% 86.79% -0.09%
==========================================
Files 782 792 +10
Lines 319391 320010 +619
==========================================
+ Hits 277498 277755 +257
- Misses 41369 41731 +362
Partials 524 524
🚀 New features to boost your workflow:
|
lquerel
requested changes
Jul 24, 2026
lquerel
left a comment
lquerel
left a comment
Contributor
There was a problem hiding this comment.
Made few suggestions to improve this test helper.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Change Summary
Added a shared test helper for the kafka reciever and exporter that spins up a broker using the rdkafka mock cluster broker. This test helper streamlines the kafka integration tests and will be used to validate the kafka receiver and exporter with edge cases such as when a consumer leaves and joins the consumer group causing rebalance. This test helper simplifies the component connection to the broker, allows inspection of the broker state, and can perform fault injections and rebalance scenarios.
What issue does this PR close?
How are these changes tested?
Updated kafka tests and added example tests using the test suite
Are there any user-facing changes?
no
Changelog
.chloggen/*.yamlentry