junrao commented on code in PR #14385:
URL: https://github.com/apache/kafka/pull/14385#discussion_r1327614488
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -667,6 +683,35 @@ private static ClusterResourceListeners
confi
junrao commented on code in PR #14385:
URL: https://github.com/apache/kafka/pull/14385#discussion_r1327801964
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -667,6 +683,35 @@ private static ClusterResourceListeners
confi
junrao commented on code in PR #14385:
URL: https://github.com/apache/kafka/pull/14385#discussion_r1327802559
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java:
##
@@ -141,4 +146,53 @@ public static List>
configuredConsumerIntercept
junrao commented on code in PR #14385:
URL: https://github.com/apache/kafka/pull/14385#discussion_r1329117484
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumerTest.java:
##
@@ -361,6 +364,84 @@ public void testWakeup_committed() {
junrao commented on code in PR #14385:
URL: https://github.com/apache/kafka/pull/14385#discussion_r1329179154
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumerTest.java:
##
@@ -361,6 +364,84 @@ public void testWakeup_committed() {