手动选择性启动Kafka Streams处理器

而上述方法则无条件适用自动启动false通过应用程序中的所有Kafka Streams处理器StreamsBuilderFactoryManager通常希望只有单独选定的Kafka Streams处理器不自动启动。例如，假设你的应用程序中有三个不同的功能（处理器），其中一个处理器你不想在启动应用时启动它。这里有一个这样的例子。spring-doc.cadn.net.cn

@Bean
public Function<KStream<?, ?>, KStream<?, ?>> process1() {

}

@Bean
public Consumer<KStream<?, ?>> process2() {

}

@Bean
public BiFunction<KStream<?, ?>, KTable<?, ?>, KStream<?, ?>> process3() {

}

在上述情景中，如果你设定Spring.kafka.streams.auto-startup自false那么，应用程序启动时任何处理器都不会自动启动。在这种情况下，你必须按照上述描述通过调用程序启动它们开始（）关于标的StreamsBuilderFactoryManager. 但是，如果我们有选择性地禁用一个处理器的用例，那么你必须设置自动启动对该处理器的个别绑定。假设我们不希望过程3自动启动功能。这是一个双功能带有两个输入绑定 -process3-in-0和process3-in-1. 为了避免该处理器自动启动，你可以选择这些输入绑定并设置自动启动在它们上。无论你选择哪种绑定;如果你愿意，可以设置自动启动自false两个绑定都用，但一个就足够了。因为它们共用同一个出厂豆，所以你不必在两个绑定上都把自动启动设为false，但为了清晰起见，这样做可能更合理。spring-doc.cadn.net.cn

这里有 Spring Cloud Stream 属性，可以用来禁用该处理器的自动启动功能。spring-doc.cadn.net.cn

spring.cloud.stream.bindings.process3-in-0.consumer.auto-startup: false

或spring-doc.cadn.net.cn

spring.cloud.stream.bindings.process3-in-1.consumer.auto-startup: false

然后，你可以手动启动处理器，要么用 REST 端点，要么使用Bindings终点如下所示的API。为此，你需要确保Spring Boot执行器依赖于类路径。spring-doc.cadn.net.cn

curl -d '{"state":"STARTED"}' -H "Content-Type: application/json" -X POST http://localhost:8080/actuator/bindings/process3-in-0

或spring-doc.cadn.net.cn

@Autowired
BindingsEndpoint endpoint;

@Bean
public ApplicationRunner runner() {
    return args -> {
        endpoint.changeState("process3-in-0", State.STARTED);
    };
}

关于该机制，请参阅参考文献中的这一部分。spring-doc.cadn.net.cn

通过禁用绑定来控制绑定自动启动如本节所述，请注意，这仅适用于消费者装订。换句话说，如果您使用生产者装订，过程3出局0，虽然该生产者绑定使用相同的功能，但对关闭处理器自动启动没有任何影响StreamsBuilderFactoryBean作为消费者装订。