[jira] [Created] (KAFKA-4337) Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets created in only one of the specified zookeeper)

[Bharat Patel (JIRA)]

Bharat Patel created KAFKA-4337:
-----------------------------------

             Summary: Create topic in multiple zookeepers with Kafka 
AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets 
created in only one of the specified zookeeper)
                 Key: KAFKA-4337
                 URL: https://issues.apache.org/jira/browse/KAFKA-4337
             Project: Kafka
          Issue Type: Bug
          Components: admin
            Reporter: Bharat Patel


 Want to use below code snippet to create topic in multiple zookeepers with 
Kafka Java APIS. when I specify 2 zookeeprs IPs in zookeeperConnect variable it 
only creates topic in anyone of zookeeper. Both the zookeeper are 2 different 
kafka clusters.

 String zookeeperConnect = zookeeperIPs; // Multiple zookeeper IPs
   int sessionTimeoutMs = 10 * 1000;
   int connectionTimeoutMs = 8 * 1000;

   try {
    ZkClient zkClient = new ZkClient(
                zookeeperConnect,
                sessionTimeoutMs,
                connectionTimeoutMs,
                ZKStringSerializer$.MODULE$);

    boolean isSecureKafkaCluster = false;
    ZkUtils zkUtils = new ZkUtils(zkClient, 
    new ZkConnection(zookeeperConnect), isSecureKafkaCluster);

     String topic1 = "nameofTopictobeCreated";
     int partitions = 1;
     int replication = 1;
     Properties topicConfig = new Properties(); // add per-topic configurations 
settings here
     AdminUtils.createTopic(zkUtils, topic1, partitions, replication, 
topicConfig);




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)