Spring Kafka禁用从主题列表中收听

Question

我们使用spring kafka配置来接收来自上游系统的消息。我们有用于主题配置的java配置

@Bean(id="firstcontainer")
protected ConcurrentMessageListenerContainer createContainerInstance(...) {
//topics addition
}


@Bean(id="secondcontainer")
protected ConcurrentMessageListenerContainer createContainerInstance(...) {
//topics addition
}


@KafkaListener(firstcontainer)
public void listenerFirst(){

}

@KafkaListener(secondcontainer)
public void listenerSecond(){

}

这段代码工作得非常好，因为我们有单独的容器工厂。现在我们需要启动此应用程序的多个实例，其中一个实例将监听firstContainer，而第二个Container将被禁用

并且对于第二个实例，它只会启用第二个容器并禁用第一个容器。有人能帮助了解是否可以禁用从主题（主题列表）中监听吗？

Answer 1

>

如果您仍然想在应用程序中保留几个bean，那么就有Spring的Profile功能。通过这种方式，您应该将您的KafkaListener方法分为不同的类，并用适当的配置文件标记它们的组件，该配置文件同样可以在外部激活。

Apache Kafka的概念是消费者组，这意味着同一组中的所有消费者都加入到代理中，但只有一个消费者会使用主题中单个分区的记录。这种方式与应用程序实例的数量无关，您仍然可以保持一致性，因为在正确使用Kafka组的情况下，无需担心重复。