【问题标题】:KafkaConsumer and KafkaProducer idle time configurationKafkaConsumer 和 KafkaProducer 空闲时间配置
【发布时间】:2017-12-18 08:45:14
【问题描述】:

我们的应用程序运行时间很长,需要一直运行到停止/终止。其配置是为类型为long 的生产者和消费者设置connections.max.idle.ms。有没有办法设置为无限,不要关闭,或类似的东西?

或者,假设 connections.max.idle.ms 设置为 10 分钟,生产者空闲 20 分钟,因为没有要生产的东西。后期Producer需要生产消息,Producer会自动唤醒吗?

【问题讨论】:

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


    【解决方案1】:

    在您的情况下,生产者将在生产者再次开始发送消息后自动使用 Kafka 代理重新创建通道。

    connections.max.idle.ms过期时,客户端代码会关闭通道以减少资源使用。如果要禁用此行为,可以将其设置为 -1。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2013-09-10
      • 2012-08-09
      • 2021-04-26
      • 1970-01-01
      • 2011-07-13
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多