showuon commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r802633329
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
##
@@ -648,10 +648,14 @@ private void maybeUpdat
showuon commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r802624600
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -1791,4 +1793,33 @@ class PlaintextConsumerTest extends BaseCons
showuon commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r801269210
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -1791,4 +1793,33 @@ class PlaintextConsumerTest extends BaseCons