私有整数并发的默认值是多少,在concurrentkafkalistenercontainerfactory.java中?Kafka版本:0.10.2.1SpringKafka版本:1.0.5-发布
dddzy1tm1#
一个。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-发布我们鼓励所有1.x用户至少升级到1.3.5版本,因为由于kip-62,它的线程模型要简单得多。当前版本为2.1.7;所有这些版本都与10.2代理兼容,请参见项目页面以获取兼容性矩阵。
1条答案
按热度按时间dddzy1tm1#
一个。
https://github.com/spring-projects/spring-kafka/blob/master/spring-kafka/src/main/java/org/springframework/kafka/listener/concurrentmessagelistenercontainer.java#l59
1.0.5-发布
我们鼓励所有1.x用户至少升级到1.3.5版本,因为由于kip-62,它的线程模型要简单得多。当前版本为2.1.7;所有这些版本都与10.2代理兼容,请参见项目页面以获取兼容性矩阵。