0
Ich benutze unten Code-Snippet, um Thema in mehreren Tierpfleger mit Kafka Java APIS zu erstellen. Wenn ich 2 zookeeprs-IPs in der zoekeeperConnect-Variable festlege, erstellt sie nur ein Thema in einem Tierpfleger. Beide Tierpfleger sind 2 verschiedene Kafka-Cluster. Irgendeine Hilfe ?Thema in mehreren Tierpflegern mit Kafka erstellen AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gibt Fehler
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);