Как используется метод BindingServiceConfiguration.inputBindingLifecycle () в Spring Cloud Stream?

Question

Я хотел бы знать, как используется метод BindingServiceConfiguration.inputBindingLifecycle () в Spring Cloud Stream (для Kafka), и возможные бизнес-сценарии, которые этот метод помогает?

Answer 1

Используется платформой для start() привязки, когда приложение готово к запуску, и stop(), когда приложение закрывается.

На самом деле пользовательский код не предназначен для его вызова, особенно с Kafka, потому что его остановка приведет к перебалансированию разделов.

Было бы лучше использовать привод для приостановки / возобновления, если вы хотите на некоторое время прекратить получать сообщения (не позволяя передавать разделы другому экземпляру).