Изменения документа Confluentinc. Confluent-kafka-dotnet

Редактировал(а) Alexandr Fokin 2024/09/07 11:03
<
От версии < 1.6 >
отредактировано Alexandr Fokin
на 2020/10/03 01:04
К версии < 2.1 >
отредактировано Alexandr Fokin
на 2021/12/26 16:18
>
Изменить комментарий: К данной версии нет комментариев

Комментарий

Подробности

Свойства страницы
Родительский документ
... ... @@ -1,1 +1,1 @@
1 -Разработка.NET.Библиотеки.Провайдеры.WebHome
1 +Разработка.NET.Библиотеки.Провайдеры.Брокеры сообщений.WebHome
Теги
... ... @@ -1,1 +1,1 @@
1 -Kafka|Apache
1 +Apache|ApacheKafka|БрокерСообщений|Провайдер
Содержимое
... ... @@ -1,3 +1,10 @@
1 +Библиотека для работы с Apache.Kafka.
1 1  
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,3 +1,3 @@
1 -Основной вариант использования ApacheKafka Сonsumer это режим подписки subscribe, при котором Kafka смостоятельно распределеяет партиции топика между потребителями.
1 +Основной вариант использования ApacheKafka Сonsumer это режим подписки subscribe, при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения ConsumerGroup.
2 2  
3 -Но также есть возможность начать читать сообщения с любого смещения любой партиции через метод Assign. При этом ConsumerGroupId не будет задействована
3 +Но также есть возможность начать читать сообщения с любого смещения любой партиции через метод Assign. При этом ConsumerGroup не будет задействована