Создать несколько групп потребителей по той же теме в Kafka-Java

Question

Я хочу создать несколько потребителей или группу потребителей для одной и той же темы.Поскольку мое требование состоит в том, чтобы захватывать события из всего приложения.Если я разверну свой проект в 2 разных виртуальных машинах, разделы будут назначены только одному виртуальному компьютеру, в котором я развернусь первым, а для второго он не будет назначен для тех же тем.

Answer 1

Количество потребителей в группе потребителей должно быть равно или меньше количества разделов в теме.Если в вашей теме 1 раздел, и вы создали двух потребителей в одной группе, то один из потребителей будет простаивать (не будет получать никаких сообщений).Если номер раздела не достаточно, вы можете изменить тему, чтобы иметь больше разделов.

Answer 2

Насколько я понимаю, вы хотите получать все сообщения из темы в каждой виртуальной машине.В этом случае вы должны указывать разные group.id в свойствах потребителя при каждом развертывании вашего приложения.