关闭。这个问题需要更加突出重点。它目前不接受答案。**想改进这个问题吗？**通过编辑这篇文章更新这个问题，使它只关注一个问题。
5年前关门了。改进这个问题Kafka新手。很难弄清楚如何使用JavaAPI在0.9版本中创建主题。这个答案涉及0.8。我看到集群有查询分区信息、主题等的方法，但我看不到如何动态创建主题。
xfyts7mz1#
对于kafka，集群决定如何/是否能够创建主题。如果希望能够动态创建主题，最简单的方法是在集群上使用auto.create.topics.enable。然后，当您向不存在的主题发送消息时，集群将使用集群默认分区和复制因子创建主题。如果您没有/不想启用此功能，则在kafka客户机库中没有我所知道的方法。如果确定了，您可以查看kafka-topics.sh的内部结构，在这里您可以找到kafka如何使用核心api创建主题。编辑现在kafka提供了管理api，允许您以编程方式创建主题（以及其他内容）。见官方api文档(Kafka（1.0.0版）
1条答案
按热度按时间xfyts7mz1#
对于kafka，集群决定如何/是否能够创建主题。如果希望能够动态创建主题，最简单的方法是在集群上使用auto.create.topics.enable。然后，当您向不存在的主题发送消息时，集群将使用集群默认分区和复制因子创建主题。如果您没有/不想启用此功能，则在kafka客户机库中没有我所知道的方法。
如果确定了，您可以查看kafka-topics.sh的内部结构，在这里您可以找到kafka如何使用核心api创建主题。
编辑
现在kafka提供了管理api，允许您以编程方式创建主题（以及其他内容）。见官方api文档(Kafka（1.0.0版）