适用于多用户工厂的单Kafka列斯汀

Question

我在spring boot应用程序中定义了两个kafka消费者工厂，它们都指向不同的kafka集群。kafkaListenerContainerFactory和其他kafkaListenerContainerFactory。

要侦听从两个kafka服务器发布的消息，我必须定义两个侦听器方法，并用@KafkaListener注释标记它们，并指定topic和containerFactory属性。

查看下面的示例代码。

@KafkaListener(topics = "test-topic", containerFactory = "otherKafkaListenerContainerFactory")
public void listenTestEvent(ConsumerRecord<String, String> record) {
   // Same logic as below method
}

@KafkaListener(topics = "test-topic", containerFactory = "kafkaListenerContainerFactory")
public void listenTestEventServer2(ConsumerRecord<String, String> record) {
   // Same logic as above method
}

有没有办法通过指定容器工厂的数组将上述两种侦听器方法结合在一起？

Answer 1

不，它不是为如此异构的复杂性而设计的。最后，它会为特定的群集创建一个Kafka消费者，并注入用于消费的方法。就我记忆中的Hibernate而言，从实体到DB中的目标表只能进行一对一的映射。

因此，您可以使用具有不同注释的简单方法，但将它们委托给相同的服务方法。

或者，您可以生成多个微服务实例，以指向不同的Kafka群集。这样，您就不需要更改代码中的任何内容，只需要一个@KafkaListener。