具有 Spring 引导的多线程事务性 Kafka 生产者和消费者
Multi thread transactional Kafka producer and consumer with Spring Boot
我有一个使用 Spring 引导相关项目的项目。我想在项目中使用 Kafka 消费者和生产者的 Transactional 特性。我需要尽可能高效地在 Kafka 中生成大量消息。所以我需要一个多线程消费和生产来满足这个要求。如何使用 Spring boot 来开发多线程消费者和生产者？
参见 concurrency listener Boot property。
spring.kafka.listener.concurrency
主题的分区数必须至少与并发数一样多。
https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#message-listener-container
我有一个使用 Spring 引导相关项目的项目。我想在项目中使用 Kafka 消费者和生产者的 Transactional 特性。我需要尽可能高效地在 Kafka 中生成大量消息。所以我需要一个多线程消费和生产来满足这个要求。如何使用 Spring boot 来开发多线程消费者和生产者？
参见 concurrency listener Boot property。
spring.kafka.listener.concurrency
主题的分区数必须至少与并发数一样多。
https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#message-listener-container