Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add OffsetFetch and OffsetCommit #8

Open
wants to merge 2 commits into
base: master
Choose a base branch
from

Conversation

Edgpaez
Copy link

@Edgpaez Edgpaez commented Oct 29, 2024

First of all thank you for this package and the work you've put into it.

I have implemented OffsetCommit Request (Version 5) and OffsetFetch Request (Version 6). This is tested against Kafka 2.2.2.

This enables the tracking of:

  • consumer groups
  • when a new consumer first joins or a rebalance occurs.

I did not implement CollectClientMetrics for these requests since we're not using metrics at the moment.

Hope this is useful!

PS: Happy to modify this further if you think it's necessary 👍

@Edgpaez Edgpaez force-pushed the add-offset-fetch-and-commit branch from d470c76 to b2d1f3b Compare October 29, 2024 18:54
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant