我使用Spring Cloud Stream -https://github.com/sandeep540/kafka-streams-spring3-cloud-java17编写了一个小型KStreams处理器
这里我阅读到了Kafka主题“输入主题”的5个分区，处理它并将其发送到另一个主题
当我运行这个程序时，尽管在application.yml中提供了分区属性，但我只能看到所有5个分区的1个线程
我的要求是有5个线程运行（每个分区1个），什么是我错过了，任何帮助在这里感谢
我使用Spring Cloud Stream -https://github.com/sandeep540/kafka-streams-spring3-cloud-java17编写了一个小型KStreams处理器
这里我阅读到了Kafka主题“输入主题”的5个分区，处理它并将其发送到另一个主题
当我运行这个程序时，尽管在application.yml中提供了分区属性，但我只能看到所有5个分区的1个线程
我的要求是有5个线程运行（每个分区1个），什么是我错过了，任何帮助在这里感谢
1条答案
按热度按时间zbdgwd5y1#
可以使用
num.stream.threads属性配置流线程数：这指定Kafka Streams应用程序示例中的流线程数。流处理代码在这些线程中运行。有关Kafka Streams线程模型的详细信息，请参阅线程模型。
https://docs.confluent.io/platform/current/streams/developer-guide/config-streams.html#num-stream-threads
有关更多信息，请参阅Confluent关于Kafka Streams线程模型的优秀文档。