multithreading - 使用 Spring Boot 的多线程事务 Kafka 生产者和消费者

Question

我有一个使用 Spring Boot 相关项目的项目。我想在项目中使用Kafka消费者和生产者的事务特性。我需要尽可能高效地在 Kafka 中生成大量消息。所以我需要一个多线程消费和生产来满足这个要求。如何使用 Spring Boot 开发多线程消费者和生产者？

标签： multithreadingspring-bootapache-kafkaspring-kafkaspring-transactions

Answer 1

请参阅concurrency 侦听器 Boot 属性。

spring.kafka.listener.concurrency

主题的分区数必须至少与并发数一样多。

https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#message-listener-container