Repository navigation
test(cluster): test the Kafka gateway and the SDK on split primaries - #4642
Merged
Merged
Conversation
The script stops and restarts Iggy nodes under Kafka load, and fails if a record is missing or an offset reads back wrong.
One producer sends in turn to 3 partitions whose primaries sit on different nodes, the case of #4436.
Codecov Report✅ All modified and coverable lines are covered by tests. Additional details and impacted files@@ Coverage Diff @@
## master #4642 +/- ##
============================================
+ Coverage 81.13% 90.82% +9.69%
- Complexity 3104 3109 +5
============================================
Files 1479 1479
Lines 361309 361306 -3
Branches 305179 305434 +255
============================================
+ Hits 293148 328167 +35019
+ Misses 61219 26250 -34969
+ Partials 6942 6889 -53
🚀 New features to boost your workflow:
|
numinnex
approved these changes
Oct 28, 2026
mmodzelewski
approved these changes
Oct 28, 2026
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
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.
Which issue does this PR address?
Relates to #4409.
Relates to #4436.
Rationale
No test ran the Kafka gateway against an Iggy cluster. The gateway docs still told users to set
auto.offset.reset=earliestin a cluster. The reason was #4409: an offset read went to the node that the gateway dials. That node can be a backup that did not apply the commit yet. #4561 sends offset reads to the partition primary, but nothing checked this through the gateway. Also, nothing measured the effect of an Iggy node stop on a Kafka client.#4436 reported that once partition primaries sit on different nodes, the SDK moved its session on nearly every send. The gateway talks to Iggy through such an SDK session. #4506 and #4561 replaced that send path. #4437 held the failing test, but it used the retired route code 103 and was closed on 2026-10-24. So no test covers one producer that sends to partitions on different primaries.