evolution-gaming / kafka-flow / 29431600774

83%

Build Type

push

Committed by web-flow

Commit Message

Refresh consumer group metadata on poll (#854)

Track the Kafka consumer generation with a read after every poll instead
of capturing it at assignment. A rebalance can advance the generation
while leaving this member's partitions unchanged; a captured token then
goes stale and the retained partition's next transactional commit is
spuriously fenced (safe - a fenced commit writes nothing - but not
stable). A post-poll refresh follows the silent bump. The pre-join
negative generation is never published (the coordinator skips validating
it, so it would land ungated).

Rebased onto master: the "derive transactional config from the flow"
refactor and the EXPERIMENTAL marking this work was stacked on have since
merged separately, so only the refresh remains here - the Consumer
post-poll refresh (with the negative-generation guard), its ConsumerSpec,
the TopicFlowSpec live-reader assertions, and the docs for the refresh
and rebalance-protocol coverage.


Claude-Session: https://claude.ai/code/session_012ufJ4z7CT68rDwfCaLiMeF

Co-authored-by: Claude Opus 4.8 <noreply@anthropic.com>

Coverage Stats

2 of 2 new or added lines in 1 file covered. (100.0%)

77 existing lines in 15 files now uncovered.

1776 of 2118 relevant lines covered (83.85%)

1.28 hits per line