Многократный потребитель в кластере kafka - PullRequest
Новая
       8

Многократный потребитель в кластере kafka

0 голосов
/ 10 апреля 2020

У меня есть один kakfa topi c, который имеет 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, нужно ли мне создавать копию моего метода (потреблять), чтобы создать больше потребителей, или у нас есть альтернативные варианты?

...