我使用 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)