通过java创建kafka主题时出现异常

【问题标题】：Exception when creating kafka topic through java通过java创建kafka主题时出现异常
【发布时间】：2015-03-22 10:29:51
【问题描述】：

我正在尝试使用以下代码Source通过 AdminCommand 创建一个 kafka 主题

 ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$);
    AdminUtils.createTopic(zkClient, "pa_reliancepoc_telecom_usageevent", 10, 1, new Properties());

但得到以下异常

Exception in thread "main" org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)

【问题讨论】：

标签： java apache-zookeeper apache-kafka kafka-consumer-api

【解决方案1】：

从你的例外情况来看，它是could not able to connect zookeeper。在您的代码中，

ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$);

第一个参数是zookeeper host，我不知道你在kafkaHost变量中有什么，顾名思义我认为你已经在那个变量中存储了kafka host。通过给出zookeeper host 来更改第一个参数。例如，

String zkHosts = "xxx.xxx.xx.xx:2181";
ZkClient zkClient = new ZkClient(zkHosts, 10000, 10000, ZKStringSerializer$.MODULE$);

如果您有多个动物园管理员，则以逗号分隔的字符串形式提供。例如，

String zkHosts = "xxx.xxx.xx.xx:2181,yyy.yyy.yy.yy:2181";

【讨论】：