showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r86375
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java:
##
@@ -148,18 +148,18 @@ public class
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r863399174
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java:
##
@@ -148,18 +148,18 @@ public class
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r863325064
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -336,13 +332,16 @@ ClusterAssignment
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r861753163
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java:
##
@@ -230,15 +230,16 @@ public static
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r861528608
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java:
##
@@ -230,15 +230,16 @@ public static
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r860546268
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -298,20 +329,21 @@ protected Map
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r860454746
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -1142,107 +982,65 @@ private void
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r857284813
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -1375,24 +1171,6 @@ private void
showuon commented on code in PR #11983:
URL: https://github.com/apache/kafka/pull/11983#discussion_r857235521
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -1142,107 +982,65 @@ private void