如果 autoStartup 设置为 false，如何手动启动 Spring Cloud Stream Binders

Question

我正在使用 spring-cloud-starter-stream-kafka 创建 Kafka 消费者绑定，并且我已将 spring.cloud.stream.bindings.input.consumer.autoStartup 配置为 false

(https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2.0.RELEASE/spring-cloud-stream.html#_consumer_properties).

我想知道我必须在什么时候注入什么来启动活页夹（例如通过属性启用的配置）。我找不到任何关于此的文档。

谢谢。

Answer 1

使用BindingsEndpoint bean 更改状态。

查看我对this question的回复。

目前，执行器必须在类路径上。