【问题标题】:what is the default value for kafka.concurrency in ConcurrentKafkaListenerContainerFactory?ConcurrentKafkaListenerContainerFactory 中 kafka.concurrency 的默认值是多少?
【发布时间】:2018-06-14 22:20:23
【问题描述】:

private Integer concurrency; 的默认值是多少,在 ConcurrentKafkaListenerContainerFactory.java 中?

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

【问题讨论】:

    标签: apache-kafka kafka-consumer-api spring-kafka


    【解决方案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-发布

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2014-10-20
      • 2018-07-12
      • 2015-09-07
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2012-07-05
      • 1970-01-01
      相关资源
      最近更新 更多