如何禁用Spring Cloud Stream Kafka消费者

Question

以下是我的情况：

我们有一个Spring cloud Stream 3 Kafka服务连接到同一个代理中的多个主题，但我想基于属性控制连接到特定主题。

每个主题都有自己的活页夹和绑定，但代理对所有人来说都是一样的。

我尝试使用下面的属性禁用绑定（这是我到目前为止找到的唯一解决方案），这适用于StreamListener不接收消息，但与主题的连接和重新平衡仍在发生。

spring:
  cloud:
    stream:
      bindings:
        ...
        anotherBinding:
          consumer:
            ...
            autostartup: false
  

我想知道活页夹级别是否有任何设置阻止它启动。其中一个主题消费者应该只在其中一个环境中可用。

谢谢

Answer 1

通过将AutoStartup设置为false来禁用绑定应该可以工作，我不确定问题是什么。

看起来您使用的是新功能模型，而是 StreamListener。如果您使用的是功能模型，则可以尝试以下另一件事。可以通过在运行时不包含相应的函数来禁用绑定。例如，假设您有以下两个使用者。

@Bean
public Consumer<String> one() {}

@Bean
public Consumer<String> two() {}

运行此应用程序时，您可以提供属性＜code＞spring.cloud.function。definition＜/code＞以包含/排除函数。例如，当您使用spring.cloud.function运行它时。definition=一个，那么消费者两个将根本不会被激活。使用spring.cloud.function运行时。definition=two，则消费者one将不会被激活。

上述方法的缺点是，如果您决定在应用程序启动后启动另一个函数（在另一个功能上，给定＜code＞autoStartup＜/code＞为＜code＞false＜/code〕），则它将无法工作，因为它不是通过＜code＞spring.cloud.function.definition＜/code＜的原始绑定的一部分。但是，根据您的需求，这可能不是一个问题，因为您知道相应主题的目标环境。换句话说，如果您知道消费者＜code＞one＜/code＞需要始终从主题＜code＞one