Kafka 0.9 - 如何通过java api创建主题

卡夫卡新人.

在找出如何使用java-api在0.9版本中创建主题时遇到困难.

这个答案涉及0.8.

我看到群集有查询分区信息,主题等的方法.但我看不出如何动态创建主题.

1> David Krieg..：

---

对于Kafka,群集确定如何/如果您能够创建主题.如果您希望能够动态创建主题,最简单的方法是在群集上使用auto.create.topics.enable.然后,当您向不存在的主题发送消息时,群集将使用群集默认分区和复制因子创建主题.如果您没有/希望启用此功能,则Kafka客户端库中没有我知道的方法.

如果您已经确定,可以查看kafka-topics.sh的内部结构,在这里您可以找到Kafka如何使用核心API创建主题.

立即编辑 Kafka提供Admin API,允许您以编程方式创建主题(以及其他内容).请参阅官方API文档.(kafka版本1.0.0)

---

这实际上确实回答了这个问题,但是没有Java客户端API.有Scala管理员API来执行此操作,但客户端中没有Java API以编程方式创建主题,因为它仅作为管理功能/集群级别提供的内容提供.@GwenShapira支持我,所以我邀请你阅读更多关于Kafka的内容.答案是:A.您没有,您启用集群在主题的新消息上自动执行此操作.或者B.您必须深入了解Scala唯一的管理API.PS,Scala类可以从Java中使用.