You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/10/25 09:15:58 UTC
[jira] [Resolved] (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)
[ https://issues.apache.org/jira/browse/KAFKA-4337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-4337.
--------------------------------
Resolution: Not A Bug
> 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
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> 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)