多重Kafka——Spring Boot多重Kafka集群中的消费者

Question

想要从使用SpringKafka的Spring启动应用程序的不同集群上创建同质的 kafka 使用者。

即想要为已经定义的类创建一个 Kafka Consumer 对象，该对象侦听动态定义的多个集群。

例如：假设一个Spring启动应用程序S，其中包含kafkaconsumer的模板。有三个Kafka Clusters Custer1、cluster2、cluster3。应用程序S充当从每个集群生成的数据的聚合器。这里的解决方案是同一个模板的三个消费者将在并行中监听单个集群。

使用SpringKafka是否可能实现上述情况？




Answer 1

@KafkaListener无法与多个集群对话。你需要授权给真正的听众。。。

@KafkaListener(..., containerFactory="cluster1Factory")
public void listen1(...) {
    this.delegate.listen(...);
}

@KafkaListener(..., containerFactory="cluster2Factory")
public void listen2(...) {
    this.delegate.listen(...);
}

etc.