首页 > 解决方案 > kafka集群中的多个消费者

问题描述

我有一个 kakfa 主题,它有 10 个分区,我有 2 个具有相同组的消费者,如下面的 消费者 1

@KafkaListener(topics = "topic2", groupId = "group_id",containerFactory="jsonKafkaListenerContainerFactory")
    public void consume(Person person) {}

消费者2

@KafkaListener(topics = "topic2", groupId = "group_id",containerFactory="jsonKafkaListenerContainerFactory")
    public void consume(Person person) {}

如果我想增加消费者说 10,那么我是否需要创建我的方法(消费)的副本以创建更多消费者,或者我们是否还有其他选择。

标签: apache-kafkaspring-kafka

解决方案


推荐阅读