我想用java创建一个主题。这是我的密码。
String s = "--topic pt8 --create --zookeeper 10.11.6.52:2181 --replica-assignment 7";
String[] args2 = s.split(" ");
TopicCommand.main(args2);
但有一个错误:
[zkclient-eventthread-14-10.11.6.52:2181]信息o.i.z.zkeventthread-启动zkclient事件线程。
[main]info o.i.z.zkclient-正在等待keeper状态syncconnected[main eventthread]info o.i.z.zkclient-zookeper状态已更改(syncconnected)
执行topic命令时出错:java.lang.exceptionininitializererror
[zkclient-eventthread-14-10.11.6.52:2181]信息o.i.z.zkeventthread-终止zkclient事件线程。 --list --zookeeper 10.11.6.52:2181
可以得到结果。 --delete --zookeeper 10.11.6.52:2181 --topic pt7
得到 Error while executing topic command : null
.
我的pom.xml:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.10.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.10.2.1</version>
</dependency>
使用管理员:
ZkClient zkClient = new ZkClient("10.11.6.52:2181", 30000, 30000, ZKStringSerializer$.MODULE$);
ZkUtils zkUtils = ZkUtils.apply(zkClient, false);
AdminUtils.createTopic(zkUtils, "pt8", 1, 1, new Properties(), RackAwareMode.Disabled$.MODULE$);
错误:
线程“main”kafka.admin.adminoperationexception中出现异常:java.lang.ExceptionInInitializeError
1条答案
按热度按时间dsekswqp1#
不要使用shell命令并尝试从java执行它,而是使用kafka管理客户端api,它应该与kafka 0.11+一起工作。
下面是一段代码片段: