我们如何使用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());