为什么 KStreamBinder 没有 DefaultBinding 的生命周期？

Question

我在@StreamBuilder 中使用 KStream 参数。

这将通过 KStreamBinder 创建一个 DefaultBinding。

我的需求是使用Binding可视化和控制。

但是

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

您无法通过springboot /actuator/bindings 控制状态，因为生命周期为空。

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

如何控制绑定的状态？

下面是我使用的版本

org.springframework.cloud:spring-云流: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

绑定可视化控件在 Spring Cloud Stream 的 Kafka Streams 活页夹中不完全可用。如果您可以将您的用例描述为一个新的 GitHub issue，我们可以在那里进一步讨论。谢谢你。

Why doesn't KStreamBinder have a lifecycle for DefaultBinding?