我正在使用camel-kafka，spring-boot项目中的camel-spring-boot启动程序将消息从一个kafka主题路由到另一个kafka主题。
在某些主题上，我当前的应用程序（仅使用camel-kafka和camel-spring启动程序）是生产者。
有没有办法用camel-kafka增加分区数？
在camel中，我们使用URL提供。。有点像。。。 uri(kafka:localhost:9092... .
camel-kafka中是否有任何配置可以用来增加kafka主题分区数？
2条答案
按热度按时间igsr9ssn1#
不，分区数不应该在Kafka之外增加。在主题创建步骤中只能分配多个分区。然后你可以手动增加他们使用Kafka管理工具。
uinbv5nw2#
camel-kafka组件不能帮助您增加分区数。但您可以尝试使用此解决方案：
kafka：使用java更改特定主题的分区数
并在此基础上创建camelbean或camel处理器。