Я читаю документацию Кафки и пытаюсь понять, как это работает - PullRequest
0 голосов
/ 13 декабря 2018

Я читаю документацию Кафки и пытаюсь понять, как она работает.Это касается потребителей.Вкратце, тема разделена на количество разделов.Существует несколько групп потребителей, каждая из которых имеет количество экземпляров потребителей.Теперь мой вопрос: отправляет ли каждый раздел «одно и то же» сообщение каждой группе потребителей, что, в свою очередь, передается конкретному экземпляру потребителя в группе?

Если это так, как Кафка гарантирует, что сообщение обрабатывается только одним потребителем?

Пожалуйста, сообщите мне, если я что-то упустил.

1 Ответ

0 голосов
/ 13 декабря 2018

Ну, проще говоря:

  1. у нас есть тема, разделенная на разделы.

  2. у нас есть потребитель, который потребляет данные из этих тем.

  3. Потребители входят в группу потребителей, разделяя один и тот же group.id.

  4. Из темы каждый раздел потребляется одним потребителем в группах потребителей.

Пример : Тема "test" с3 раздела.Группа потребителей A: с 3 потребителями. Группа потребителей B: с 2 потребителями.

. Две группы потребителей A и B потребляют данные из темы «тест».

В группе A каждый потребитель (поэтому 3) будет использовать один раздел каждый, тогда как в групповом потребителе B (с двумя потребителями) один потребитель прочитает 2 раздела, а другой - последний.Если у нас есть последняя группа потребителей с одним потребителем внутри, она прочитает все 3 раздела этой темы.

Надеюсь, это поможет, дайте мне знать, если вы не поняли.

...