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

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

<
От версии < 2.4 >
отредактировано Alexandr Fokin
на 2022/11/07 00:41
К версии < 2.9
отредактировано Alexandr Fokin
на 2024/09/07 11:03
Изменить комментарий: Тег [Провайдер] удален

Комментарий

Подробности

Свойства страницы
Название
... ... @@ -1,1 +1,1 @@
1 -Confluentinc.Confluent-kafka-dotnet
1 +Confluentinc. Confluent-kafka-dotnet
Родительский документ
... ... @@ -1,1 +1,1 @@
1 -Разработка.Брокеры сообщений.Apache Kafka.Клиент.WebHome
1 +Разработка.NET.Работа с брокерами сообщений.WebHome
Теги
... ... @@ -1,1 +1,0 @@
1 -Apache|ApacheKafka|БрокерСообщений|Провайдер
Содержимое
... ... @@ -1,8 +1,6 @@
1 -Библиотека для работы с Apache.Kafka.
1 +| |Библиотека для работы с [[Apache Kafka>>Разработка.Брокеры сообщений.Apache Kafka.WebHome]].
2 2  Основана на библиотеке [[librdkafka>>Разработка.Другое.C plus plus.Библиотеки.librdkafka.WebHome]].
3 -
4 -----
5 -
3 +| |(((
6 6  Варианты подключения потребителей:
7 7  
8 8  * Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup.
... ... @@ -9,4 +9,30 @@
9 9  * Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign. 
10 10  В таком случае ConsumerGroup не используется.
11 11  При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение.
12 -Подход может быть использован для повторного излечения уже прочитанных ранее собщений.
10 +Подход может быть использован для повторного излечения уже прочитанных ранее сообщений.
11 +)))
12 +| |
13 +
14 +----
15 +
16 +==== Внутренние ссылки: ====
17 +
18 +====== Дочерние страницы: ======
19 +
20 +{{children/}}
21 +
22 +====== Обратные ссылки: ======
23 +
24 +{{velocity}}
25 +#set ($links = $doc.getBacklinks())
26 +#if ($links.size() > 0)
27 + #foreach ($docname in $links)
28 + #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
29 + * [[$escapetool.xml($rdoc.fullName)]]
30 + #end
31 +#else
32 + No back links for this page!
33 +#end
34 +{{/velocity}}
35 +
36 +----