Comparing main...dnwe/coop-full · IBM/sarama · GitHub
Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: IBM/sarama
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: main
Choose a base ref
...
head repository: IBM/sarama
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: dnwe/coop-full
Choose a head ref
Checking mergeability… Don’t worry, you can still create the pull request.
  • 2 commits
  • 9 files changed
  • 1 contributor

Commits on Sep 20, 2026

  1. test(functional): cover cooperative Java interoperability 

    Run mixed Java and Sarama groups with each client leading in turn. Track assignment callbacks to verify that disjoint subscriptions are retained and include an eager fallback case as a control.

Run these tests with Java clients from Kafka 2.8.2 or later, which includes the fix for KAFKA-13406.

Signed-off-by: Dominic Evans <dominic.evans@uk.ibm.com>
    @dnwe
    dnwe committed Sep 20, 2026
    Configuration menu
    Copy the full SHA
    1da27b1 View commit details
    Browse the repository at this point in the history

  2. feat(consumer): add cooperative metrics and example 

    Count assigned and revoked partitions and report the current number owned by each consumer group member. The same metrics cover eager and cooperative sessions.

Add cooperative assignor options to the consumer group example and document the two-stage rolling migration for an existing group.

Signed-off-by: Dominic Evans <dominic.evans@uk.ibm.com>
    @dnwe
    dnwe committed Sep 20, 2026
    Configuration menu
    Copy the full SHA
    45d3054 View commit details
    Browse the repository at this point in the history
Loading