Kafka AdminUtils.CreateTopic JAVA APIを使用して複数の動物園でトピックを作成するKafka 0.9.0.1でエラーが発生する

Question

以下のコードスニペットを使用して、Kafka Java APISで複数の動物園でトピックを作成します。 zookeeperConnect変数に2つのzookeeprs IPを指定すると、zookeeperの誰にでもtopicが作成されます。動物園の両者は2種類のカフカクラスターです。どんな助け？

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); 

Answer 1

AdminUtilsはすべてZKを指定しているものと見なしツールは、同じクラスタに属しているので、それらの1（ZKノードが自動的に自分自身を同期されるように）に話をするのに十分です。

2つのクラスタでトピックを作成する場合は、別のZKノードを使用するたびに2回コマンドを発行する必要があります。