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

"Specified group generation id is not valid" error should be retried #1534

Closed
emasab opened this issue Feb 23, 2023 · 1 comment
Closed

"Specified group generation id is not valid" error should be retried #1534

emasab opened this issue Feb 23, 2023 · 1 comment

Comments

@emasab
Copy link

emasab commented Feb 23, 2023

Describe the bug
The error "Specified group generation id is not valid" (code: 22) isn't retried has a subclass of KafkaJSNonRetriableError,
but in Java client and librdkafka it's retried by rejoining the group. Here in Java client and here in librdkafka

To Reproduce

  1. Run a consumer with a session timeout N seconds
  2. Disconnect the consumer from the broker for more than N seconds
  3. Reconnect the consumer to the consumer group after it has rebalanced and has a new generation id

Expected behavior
It should retry rejoining the consumer group like other errors like UnknownMemberIdException, RebalanceInProgressException and MemberIdRequiredException

Observed behavior
It's throwing a non retriable error:

Crash: KafkaJSNonRetriableError: Specified group generation id is not valid

Environment:

Pending but should happen in master version too.

Additional context

Pending

@emasab
Copy link
Author

emasab commented Feb 27, 2023

Duplicate of #1466

There's a proposed fix #1474

@emasab emasab closed this as completed Feb 27, 2023
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

No branches or pull requests

1 participant