我们如何使用API​​从IDE中在Kafka中创建主题

Question

我们如何使用API从IDE中在Kafka中创建主题，因为当我这样做时：bin/kafka-create-topic.sh --topic mytopic --replica 3 --zookeeper localhost:2181我得到错误：bash: bin/kafka-create-topic.sh: No such file or directory我照原样进行了开发人员设置。

Answer 1

要通过Java api和Kafka 0.8+创建主题，请尝试以下操作，

以下语句的首次导入

import kafka.utils.ZKStringSerializer$;

通过以下方式为ZkClient创建对象，

ZkClient zkClient = new ZkClient("localhost:2181", 10000, 10000, ZKStringSerializer$.MODULE$);

AdminUtils.createTopic(zkClient, myTopic, 10, 1, new Properties());