This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from f58c2ac KAFKA-12250; Add metadata record serde for KIP-631 (#9998)
add 5eb8a23 KAFKA-12270: Handle race condition when Connect tasks attempt
to create topics (#10032)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/WorkerSourceTask.java | 7 +-
.../org/apache/kafka/connect/util/TopicAdmin.java | 103 +++++++++++++++++++--
.../ErrorHandlingTaskWithTopicCreationTest.java | 6 +-
.../WorkerSourceTaskWithTopicCreationTest.java | 69 ++++++++++++--
.../apache/kafka/connect/util/TopicAdminTest.java | 31 +++++--
5 files changed, 192 insertions(+), 24 deletions(-)
