philipnee commented on code in PR #14357:
URL: https://github.com/apache/kafka/pull/14357#discussion_r1362361109
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##########
@@ -135,6 +146,7 @@ public void updateState(ConsumerGroupHeartbeatResponseData
response) {
public void transitionToFenced() {
resetEpoch();
transitionTo(MemberState.FENCED);
+ assignmentReconciler.startLost();
Review Comment:
sorry, you are right, i kept forgetting about the changes - after reading
the PR, due to the fact that we have to wait for the rebalance to complete to
rejoin, maybe it is best to first move to the next state, i.e. UNJOINED (or
something else is fine), and then send the heartbeat.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
