KafkaListenerEndpointRegistry 可以用于重新上传所有客户端配置吗?
Can KafkaListenerEndpointRegistry be used for re-uploading all the clients configs?
我可以在 KafkaListenerEndpointRegistry 上调用 stop() 并在调用 start() 之后重新加载所有 kafka 客户端配置吗?
简短的回答是肯定的。
但我建议只做一个暂停和恢复,而不是开始和停止。因为如果您使用多个分区,那么 stop/start 将触发消费者的重新平衡,而 pause/resume 保持原始配置,即消费者将从与之前相同的分区消费
我可以在 KafkaListenerEndpointRegistry 上调用 stop() 并在调用 start() 之后重新加载所有 kafka 客户端配置吗?
简短的回答是肯定的。 但我建议只做一个暂停和恢复,而不是开始和停止。因为如果您使用多个分区,那么 stop/start 将触发消费者的重新平衡,而 pause/resume 保持原始配置,即消费者将从与之前相同的分区消费