Skip to content

Conversation

@dantswain
Copy link
Collaborator

This seems to be related to #247 though it may not be the root cause.

We were seeing the leave group fail with an unknown_member_id, which
happens when there is a problem between the client and the broker. This
would cause the manager to exit abruptly and may be causing the rest of
the consumer group's processes to exit uncleanly.

Regardless of the error returned, we want to exit the consumer group
cleanly.

This seems to be related to #247 though it may not be the root cause.

We were seeing the leave group fail with an `unknown_member_id`, which
happens when there is a problem between the client and the broker.  This
would cause the manager to exit abruptly and may be causing the rest of
the consumer group's processes to exit uncleanly.

Regardless of the error returned, we want to exit the consumer group
cleanly.
@sourcelevel-bot
Copy link

Ebert has finished reviewing this Pull Request and has found:

  • 1 possible new issue (including those that may have been commented here).

You can see more details about this review at https://ebertapp.io/github/kafkaex/kafka_ex/pulls/248.

Copy link
Member

@bjhaid bjhaid left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is the piece of the code I least understand, looks good to me, I think you should seek an extra eye beyond mine. However if you feel confident about it you can go ahead to merge

@dantswain dantswain merged commit 1c0ca41 into master Nov 18, 2017
@dantswain dantswain deleted the graceful_leave_group branch November 18, 2017 00:42
robotarmy pushed a commit to RAM9/kafka_ex that referenced this pull request Apr 7, 2025
More gracefully handle errors on leaving consumer group
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.

4 participants