问题：
如何使用camel创建kafka主题分区
暴德运
-
null
camel-kafka中是否有任何配置，我们可以使用它来增加kafka主题分区计数？
共有1个答案
呼延哲
类似资料：
-
我有几个Samza工作运行所有阅读Kafka主题的消息，并为新主题编写新消息。为了发送新消息，我使用Samza内置的OutgoingMessageEnvelope。并使用MessageCollector发送新消息。它看起来是这样的：
-
我正在编程一个客户端工作与Kafka0.9。我想知道如何制造话题。这个答案：如何通过Java在Kafka中创建一个主题，与我所问的类似。除此之外，该解决方案仅适用于Kafka 0.8.2，这与Kafka 0.9的API有很大不同。
-
uuusing Spring Kafka org . Spring framework . Kafka . listener . concurrentmessagelistenercontainer根据ContainerProperties和主题中的分区数量创建多个侦听器。javadoc说“来自同一个分区的消息将被顺序处理”。因此，如果只有1个分区，并发性设置为10，会发生什么——不会有任何并发性
-
问题内容： 我想通过Java在Kafka（kafka_2.8.0-0.8.1.1）中创建一个主题。如果我在命令提示符下创建一个主题，并且如果我通过java api推送消息，它也可以正常工作。但是我想通过java api创建一个主题。经过长时间的搜索，我发现了以下代码， 我尝试了上面的代码，它表明创建了主题，但是无法在该主题中推送消息。我的代码有什么问题吗？还是通过其他方式实现以上目标？ 问题答案：