У меня есть тема Kafka, которая в настоящее время имеет 3 раздела. Я хочу, чтобы мои потребители читали один и тот же раздел, но каждое сообщение должно обращаться к другому потребителю круговым способом. Можно ли это достичь?Kafka распространяет сообщения из раздела среди потребителей
Для этого вам необходимо реализовать группу потребителей. Он поставляется с коробкой с Кафкой. Вы должны указать только тот же group.id, что и ваш потребитель дерева.
[edit] Но каждый потребитель будет читать в другом разделе Kafka. Я думаю, что сделать разницу потребителем для одной и той же группы, прочитанной в том же разделе, невозможно, если вы используете только API Kafka.
Подробнее в документации: http://kafka.apache.org/documentation.html#intro_consumers
Как об этом, на производителя, сообщения направляются на основе какой-то ключ. Можно отправить сообщение 1 в раздел 1, сообщение 2 в раздел 2, сообщение 3 в раздел 3. Затем вы должны сгруппировать трех пользователей в одну группу. Можно заставить потребителя 1 потреблять раздел 1, потребитель 2 потреблять раздел 2, потребитель 3 потреблять раздел 3.
Кстати, как его реализовать, зависит от того, какой клиент kafka вы используете, какие сообщения находятся. Вы должны указать более подробную информацию ....
Что вы говорите, поражает назначение разделов. Разделы не предназначены для простой балансировки нагрузки в кафке. Если вы действительно этого хотите, у вас есть два варианта.
Вы имеете в виду сообщение 1 should go to consumer 1, message 2 to consumer 2, message 3 to consumer 3? Это невозможно. – serejja
Да, это именно то, что я имел в виду. – Hubble