tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r895874082
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1327,30 +1334,39 @@ public WorkerTask doBuild(Task task,
co
tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r896737764
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1327,30 +1334,39 @@ public WorkerTask doBuild(Task task,
co
tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r897812219
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1327,30 +1334,39 @@ public WorkerTask doBuild(Task task,
co
tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r897830233
##
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java:
##
@@ -274,18 +276,23 @@ public static NewTopicBuilder defineTopic(String
topicName)
tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r900964836
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1425,6 +1426,256 @@ public WorkerTask doBuild(Task task,
}
}
+