Open cmccarthy1 opened 3 years ago
To me this happens regardless of executing commit[]
. Even launching another stale_con.q
stops original process to receive message. Is there any necessary config on producer side or broker?
The issue cannot be reproduced due to another problem. The steps are below:
stale_con.q
other_cons.q
once the stale one is up and runningcommit
function the process of stale_con.q
ceases to receive messages. Once processes with others_con.q
disappear, the lone process resumes to receive messages.
Internally raised issue
Describe the bug Committing an offset as a member of a consumer group during a group rebalance event for that group can cause the consumer to become stale thus resulting in the consumer no longer receiving messages
To Reproduce The following scripts can be used to reproduce the issue (Note that the localhost/port need to be added in accordance with your kafka installation)
Steps to reproduce:
`test1
Expected behavior If offset commit is unsuccessful the consumer should be able to retry commit or configuration should be set to allow this
Desktop (please complete the following information):