[GitHub] [kafka] urbandan commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

urbandan commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r1133617771 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java: ## @@ -360,10 +361,20 @@ public Set createTopicsWithRetry(NewTopic topicDescription,

[GitHub] [kafka] urbandan commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

urbandan commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r1130991899 ## connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaTopicBackingStore.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] urbandan commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

urbandan commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r927368455 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java: ## @@ -329,6 +334,48 @@ public Set createTopics(NewTopic... topics) { return