Изменения документа Confluentinc. Confluent-kafka-dotnet
Редактировал(а) Alexandr Fokin 2024/09/07 11:03
<
>
отредактировано Alexandr Fokin
на 2022/11/07 00:41
на 2022/11/07 00:41
отредактировано Alexandr Fokin
на 2020/08/23 13:15
на 2020/08/23 13:15
Изменить комментарий:
Update document after refactoring.
Комментарий
-
Свойства страницы (3 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Родительский документ
-
... ... @@ -1,1 +1,1 @@ 1 -Разработка.Б рокеры сообщений.Apache Kafka.Клиент.WebHome1 +Разработка.NET.Библиотеки.Провайдеры.WebHome - Теги
-
... ... @@ -1,1 +1,1 @@ 1 - Apache|ApacheKafka|БрокерСообщений|Провайдер1 +Kafka|Apache - Содержимое
-
... ... @@ -1,12 +3,3 @@ 1 -Библиотека для работы с Apache.Kafka. 2 -Основана на библиотеке [[librdkafka>>Разработка.Другое.C plus plus.Библиотеки.librdkafka.WebHome]]. 3 3 4 - ----2 +Библиотека для работы с Apache.Kafka 5 5 6 -Варианты подключения потребителей: 7 - 8 -* Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup. 9 -* Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign. 10 -В таком случае ConsumerGroup не используется. 11 -При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение. 12 -Подход может быть использован для повторного излечения уже прочитанных ранее собщений.