spring-cloud-stream - 可以在外部配置属性值更改时更改目标主题名称

Question

我使用 Spring Cloud Stream Kafka Binder 和 Spring Cloud Zookeeper 分布式配置。流应用程序正确地从外部服务器（Zookeeper）加载绑定配置并正常工作。

但是，如果我更改目标主题名称，绑定不会更改。如果我调用actuator/env或actuator/channels端点，一切正常（属性值已更新）。但是，如果我通过实现Supplier<Message>的类（具有服务注释并在 spring.cloud.function.definition 中定义）发送消息，则消息将发送到旧目的地。

外部配置更改时是否可以重新加载现有绑定？生产者和消费者方是否相同？

（依赖项：spring-cloud-starter-stream-kafka:3.1.3，spring-cloud-starter-zookeeper-config:3.0.3）

标签： spring-cloud-streamspring-cloud-stream-binder-kafkaspring-cloud-zookeeper