Изменения документа Confluentinc. Confluent-kafka-dotnet
Редактировал(а) Alexandr Fokin 2024/09/07 11:03
<
>
отредактировано Alexandr Fokin
на 2021/12/26 16:18
на 2021/12/26 16:18
отредактировано Alexandr Fokin
на 2020/11/11 13:07
на 2020/11/11 13:07
Изменить комментарий:
Update document after refactoring.
Комментарий
-
Свойства страницы (2 изменено, 0 добавлено, 0 удалено)
-
Объекты (0 изменено, 1 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Теги
-
... ... @@ -1,1 +1,1 @@ 1 - Apache|ApacheKafka|БрокерСообщений|Провайдер1 +Kafka|Apache - Содержимое
-
... ... @@ -1,10 +2,3 @@ 1 -Библиотека для работы с Apache.Kafka. 2 2 2 +Библиотека для работы с Apache.Kafka 3 3 4 -Варианты подключения потребителей: 5 - 6 -* Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup. 7 -* Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign. 8 -В таком случае ConsumerGroup не используется. 9 -При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение. 10 -Подход может быть использован для повторного излечения уже прочитанных ранее соббщений.
- XWiki.XWikiComments[0]
-
- Автор
-
... ... @@ -1,0 +1,1 @@ 1 +XWiki.cccc1808 - Комментарий
-
... ... @@ -1,0 +1,3 @@ 1 +Основной вариант использования ApacheKafka Сonsumer это режим подписки subscribe, при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения ConsumerGroup. 2 + 3 +Но также есть возможность начать читать сообщения с любого смещения любой партиции через метод Assign. При этом ConsumerGroup не будет задействована - Дата
-
... ... @@ -1,0 +1,1 @@ 1 +2020-10-03 01:04:09.493