【发布时间】:2022-02-20 15:53:54
【问题描述】:
我可以在 KafkaListenerEndpointRegistry 上调用 stop() 并在 start() 之后重新加载所有 kafka 客户端配置吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api spring-kafka
我可以在 KafkaListenerEndpointRegistry 上调用 stop() 并在 start() 之后重新加载所有 kafka 客户端配置吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api spring-kafka
简短的回答是肯定的。 但我建议只是暂停和恢复,而不是开始和停止。因为如果您使用多个分区,则停止/启动将触发消费者的重新平衡,而暂停/恢复保持原始配置,即消费者将像以前一样从同一分区消费
【讨论】: