apache-kafka - ConcurrentKafkaListenerContainerFactory 中 kafka.concurrency 的默认值是多少？

Question

的默认值是多少？私有(private)整数并发； ，在 ConcurrentKafkaListenerContainerFactory.java 中？

卡夫卡版本:0.10.2.1
spring-kafka 版本:1.0.5-RELEASE

Answer 1

一。

https://github.com/spring-projects/spring-kafka/blob/master/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java#L59

private int concurrency = 1;

1.0.5-RELEASE

鼓励所有 1.x 用户升级到至少 1.3.5，因为它具有更简单的线程模型，这要归功于 KIP-62。当前版本是 2.1.7；所有这些版本都与 10.2 代理兼容，请参阅 the project page为兼容性矩阵。