lianetm commented on code in PR #14413:
URL: https://github.com/apache/kafka/pull/14413#discussion_r124044
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -19,56 +19,91 @@
import org.apache.kafka.common.message.Consum
lianetm commented on code in PR #14413:
URL: https://github.com/apache/kafka/pull/14413#discussion_r121553
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -19,56 +19,91 @@
import org.apache.kafka.common.message.Consum
lianetm commented on code in PR #14413:
URL: https://github.com/apache/kafka/pull/14413#discussion_r114252
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -19,56 +19,91 @@
import org.apache.kafka.common.message.Consum
lianetm commented on code in PR #14413:
URL: https://github.com/apache/kafka/pull/14413#discussion_r1332210545
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -149,92 +212,84 @@ private boolean maybeTransitionToStable() {