0

我在@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-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

请回答我的问题。谢谢你。

4

1 回答 1

0

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

于 2020-02-18T22:18:33.260 回答