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

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

<
От версии < 2.1 >
отредактировано Alexandr Fokin
на 2021/12/26 16:18
К версии < 2.8 >
отредактировано Alexandr Fokin
на 2022/11/27 23:41
>
Изменить комментарий: Update document after refactoring.

Комментарий

Подробности

Свойства страницы
Название
... ... @@ -1,1 +1,1 @@
1 -Confluentinc.Confluent-kafka-dotnet
1 +Confluentinc. Confluent-kafka-dotnet
Родительский документ
... ... @@ -1,1 +1,1 @@
1 -Разработка.NET.Библиотеки.Провайдеры.Брокеры сообщений.WebHome
1 +Разработка.NET.Работа с брокерами сообщений.WebHome
Содержимое
... ... @@ -1,6 +1,12 @@
1 -Библиотека для работы с Apache.Kafka.
1 +Библиотека для работы с [[Apache Kafka>>Разработка.Брокеры сообщений.Apache Kafka.WebHome]].
2 +Основана на библиотеке [[librdkafka>>Разработка.Другое.C plus plus.Библиотеки.librdkafka.WebHome]].
2 2  
4 +----
3 3  
6 +{{children/}}
7 +
8 +----
9 +
4 4  Варианты подключения потребителей:
5 5  
6 6  * Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup.
... ... @@ -7,4 +7,4 @@
7 7  * Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign. 
8 8  В таком случае ConsumerGroup не используется.
9 9  При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение.
10 -Подход может быть использован для повторного излечения уже прочитанных ранее соббщений.
16 +Подход может быть использован для повторного излечения уже прочитанных ранее сообщений.
XWiki.XWikiComments[0]
Автор
... ... @@ -1,1 +1,0 @@
1 -XWiki.cccc1808
Комментарий
... ... @@ -1,3 +1,0 @@
1 -Основной вариант использования ApacheKafka Сonsumer это режим подписки subscribe, при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения ConsumerGroup.
2 -
3 -Но также есть возможность начать читать сообщения с любого смещения любой партиции через метод Assign. При этом ConsumerGroup не будет задействована
Дата
... ... @@ -1,1 +1,0 @@
1 -2020-10-03 01:04:09.493