ensureTopicCreated
public static boolean ensureTopicCreated(java.lang.String bootstrapServers,
java.lang.String topicName,
int partitions,
short replication)
throws org.apache.kafka.common.KafkaException,
java.lang.InterruptedException
Create Tier Topic if one does not exist.
- Parameters:
bootstrapServers
- Bootstrap Servers for the brokers where Tier Topic should be stored.
topicName
- The Tier Topic topic name.
partitions
- The number of partitions for the Tier Topic.
replication
- The replication factor for the Tier Topic.
- Returns:
- boolean denoting whether the operation succeeded (true if topic already existed)
- Throws:
org.apache.kafka.common.KafkaException
java.lang.InterruptedException