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

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 2.1.1
• Component/s: core
• Assignee: huxihx
• Reporter: Lucas Bradstreet
• Created: 18/Mar/19 23:50
• Updated: 02/May/20 15:09
• Resolved: 16/Oct/19 01:14

Description

Imagine the following pattern to ensure topic creation in an application:

1. Attempt to create a topic with # partitions P and replication factor R.
2.  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.

 

Issue Links

• is duplicated by: KAFKA-8875 CreateTopic API should check topic existence before replication factor
• links to: GitHub Pull Request #6472