Пауза Spring Cloud Stream Kafka переплет программно

Question

Я работаю над приложением Spring Boot, которое использует Spring Cloud Stream для интеграции с Kafka.

Мне нужно программно приостановить прием сообщений от Кафки. Я представляю возможность управления жизненным циклом привязок по конечной точке привода ( docs ). Так что я могу autowire org.springframework.cloud.stream.endpoint.BindingsEndpoint и использовать его общедоступными методами. Но мне кажется немного странным ...

Есть ли лучший способ программного управления жизненным циклом привязок?

Answer 1

Это нормально, чтобы использовать этот бин BindingsEndpoint в своем собственном коде. Его цель - действительно управлять жизненным циклом привязок. С этим бином есть простой бонус, который он представляет в качестве конечной точки привода для управления связыванием через REST.

В противном случае вы бы пошли путем копирования / вставки логики BindingsEndpoint ...