我有一个项目，它使用springboot相关的项目。我想在项目中使用kafka消费者和生产者的事务特性。我需要尽可能高效地用Kafka语言传达很多信息。因此，我需要一个多线程消费和生产这一要求。如何使用SpringBoot开发多线程使用者和生产者？
u0njafvf1#
看到了吗 concurrency 侦听器启动属性。
concurrency
spring.kafka.listener.concurrency
主题的分区数必须至少与并发分区数相同。https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#message-侦听器容器
1条答案
按热度按时间u0njafvf1#
看到了吗
concurrency侦听器启动属性。主题的分区数必须至少与并发分区数相同。
https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#message-侦听器容器