【问题标题】:Can KafkaListenerEndpointRegistry be used for re-uploading all the clients configs?KafkaListenerEndpointRegistry 可以用于重新上传所有客户端配置吗?
【发布时间】:2022-02-20 15:53:54
【问题描述】:

我可以在 KafkaListenerEndpointRegistry 上调用 stop() 并在 start() 之后重新加载所有 kafka 客户端配置吗?

【问题讨论】:

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


    【解决方案1】:

    简短的回答是肯定的。 但我建议只是暂停和恢复,而不是开始和停止。因为如果您使用多个分区,则停止/启动将触发消费者的重新平衡,而暂停/恢复保持原始配置,即消费者将像以前一样从同一分区消费

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2014-02-12
      • 1970-01-01
      • 2011-03-10
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多