[ https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551730#comment-17551730 ]
Sagar Rao commented on KAFKA-13970: ----------------------------------- [~durban] , I couldn't find org.apache.kafka.connect.util.TopicAdmin#createTopicsWithRetry in the class TopicAdmin. Also, when you said `handles the case when there aren't enough brokers" did you mean this [https://github.com/apache/kafka/blob/0586f544ef5a3e2ffa263babc811568ce672dfa1/connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java#L421-L425?] > TopicAdmin topic creation should be retried on TimeoutException > --------------------------------------------------------------- > > Key: KAFKA-13970 > URL: https://issues.apache.org/jira/browse/KAFKA-13970 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Reporter: Daniel Urban > Assignee: Sagar Rao > Priority: Major > > org.apache.kafka.connect.util.TopicAdmin#createTopicsWithRetry handles the > case when there aren't enough brokers in the cluster to create a topic with > the expected replication factor. This logic should also handle the case when > there are 0 brokers in the cluster, and should retry in that case. -- This message was sent by Atlassian Jira (v8.20.7#820007)