guozhangwang commented on PR #13270: URL: https://github.com/apache/kafka/pull/13270#issuecomment-1434909837
As for this PR, I'm actually thinking if it makes sense to introduce a new state inside `MemberState`, e.g. "ABNORMAL" to indicate that the consumer is not usable at the moment --- even if it can still successfully fetch records since it does not rely on the heartbeat thread --- and under that state we should not proceed by returning any more data, in order to notify the caller of this consumer. cc @kirktrue @philipnee -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org