You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Lucas Bradstreet (JIRA)" <ji...@apache.org> on 2019/03/18 23:51:00 UTC

[jira] [Created] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

Lucas Bradstreet created KAFKA-8125:
---------------------------------------

             Summary: Check for topic existence in CreateTopicsRequest prior to creating replica assignment
                 Key: KAFKA-8125
                 URL: https://issues.apache.org/jira/browse/KAFKA-8125
             Project: Kafka
          Issue Type: Improvement
          Components: core
    Affects Versions: 2.1.1
            Reporter: Lucas Bradstreet


Imagine the following pattern to ensure topic creation in an application:
 # Attempt to create a topic with # partitions P and replication factor R.
 #  If topic creation fails with TopicExistsException, continue. If topic creation succeeds, continue, the topic now exists.

This normally works fine. However, if the topic has already been created, but if the number of live brokers < R, then the topic creation will fail an org.apache.kafka.common.errors.InvalidReplicationFactorException, even though the topic already exists.

This could be avoided if we check whether the topic exists prior to calling AdminUtils.assignReplicasToBrokers.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)