Изменения документа Apache Kafka

Редактировал(а) Alexandr Fokin 2024/09/07 11:00

<
От версии < 18.1 >
отредактировано Alexandr Fokin
на 2021/08/19 10:14
К версии < 17.9 >
отредактировано Alexandr Fokin
на 2021/08/18 20:59
>
Изменить комментарий: Добавлен комментарий

Комментарий

Подробности

Свойства страницы
Содержимое
... ... @@ -7,13 +7,12 @@
7 7  В более старых версиях Kafka zookeeper отвечал и за хранение оффсетов, но сейчас они хранятся в специальном топике __consumer_offsets на брокере
8 8  
9 9  **Apache Kafka**
10 +Producer (Отправитель)
11 +Consumer (Получатель)
12 +Topic (Отчасти схож с очередью)
13 +Partition (Topic может содержаться несколько разделов, позволяющих работать параллельно нескольким Consumer) (Данные находящиеся в разных partition одного topic не дублируют друг друга)
14 +CosumerGroup (Consumers, находящиеся в разных CosumerGroup, читают данные параллельно и независимо друг от друга. (Получают одни и те же сообщения)) (В рамках одной ConsumerGroup кол-во активных Consumer не может быть больще чем кол-во partitions. Неактивные Consumer могут быть резервными и автоматически будут подключены, если активный Consumer выйдет из строя)
10 10  
11 -* Producer (Отправитель)
12 -* Consumer (Получатель)
13 -* Topic (Отчасти схож с очередью)
14 -* Partition (Topic может содержаться несколько разделов, позволяющих работать параллельно нескольким Consumer) (Данные находящиеся в разных partition одного topic не дублируют друг друга)
15 -* CosumerGroup (Consumers, находящиеся в разных CosumerGroup, читают данные параллельно и независимо друг от друга. (Получают одни и те же сообщения)) (В рамках одной ConsumerGroup кол-во активных Consumer не может быть больще чем кол-во partitions. Неактивные Consumer могут быть резервными и автоматически будут подключены, если активный Consumer выйдет из строя)
16 -
17 17  Статьи:
18 18  https://habr.com/ru/company/avito/blog/465315/
19 19  https://ksqldb.io/quickstart.html