Почему у KStreamBinder нет жизненного цикла для DefaultBinding?

Question

Я использую параметр KStream в @ StreamBuilder.

Это создаст DefaultBinding через KStreamBinder.

Мое требование - использовать визуализацию и контроль Binding.

Однако

return new DefaultBinding <> (name, null, outboundBindTarget, null);

Вы не можете контролировать состояние с помощью пружинной загрузки / привода / привязок, поскольку жизненный цикл равен нулю.

(POST /actuator/bindings/{bindings-name} {"state":"PAUSED"})

Как я могу контролировать состояние a Binding?

Ниже используется версия, которую я использую.

• org.springframework.cloud: spring-cloud-stream: 3.0.1.RELEASE
• org .springframework.cloud: spring-cloud-stream-binder-kafka-core: 3.0.1.RELEASE
• org.springframework.cloud: spring-cloud-stream-binder-kafka-streams: 3.0.1. RELEASE
• org. apache .kafka: kafka-streams: 2.3.1

пожалуйста, ответьте на мой вопрос. Спасибо.

Answer 1

Элементы управления визуализацией привязки не полностью доступны в связывателе Kafka Streams в Spring Cloud Stream. Если вы можете описать ваш вариант использования как новую проблему GitHub , мы можем обсудить это далее. Спасибо.