2
83%
master: 83%

Ran 15 Jul 2026 04:21PM UTC

Files 103

Run time 8s

Badge

Embed ▾

Committed 15 Jul 2026 04:14PM UTC coverage: 70.828% (-0.3%) from 71.152%

Job # 29431600774.2

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

1146 of 1618 relevant lines covered (70.83%)

0.81 hits per line

evolution-gaming / kafka-flow / 29431600774 / 2
83%
master: 83%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 29431600774.2

evolution-gaming / kafka-flow / 29431600774 / 2 83% master: 83%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 29431600774.2

evolution-gaming / kafka-flow / 29431600774 / 2
83%
master: 83%

README BADGES
x