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.

Sign up for GitHub

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

Jump to bottom

KAFKA-17017: AsyncKafkaConsumer#unsubscribe does not clean the assigned partitions #16449

Open

FrankYang0529 wants to merge 1 commit into apache:trunk from FrankYang0529:KAFKA-17017

Member

FrankYang0529 commented Jun 25, 2024

Add subscriptions.unsubscribe to AsyncKafkaConsumer#unsubscribe when there is no group id.
Add subscriptions.unsubscribe to MembershipManagerImpl#leaveGroup when isNotInGroup is true.
Add related unit test.

Committer Checklist (excluded from commit message)

Verify design and implementation
Verify test coverage and CI build status
Verify documentation (including upgrade notes)


          KAFKA-17017: AsyncKafkaConsumer#unsubscribe does not clean the assign…

d9f4757

…ed partitions

Signed-off-by: PoAn Yang <[email protected]>

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment