Исходный код вики Confluentinc. Confluent-kafka-dotnet

Редактировал(а) Alexandr Fokin 2024/09/07 11:03
Последние авторы
1 | |Библиотека для работы с [[Apache Kafka>>Разработка.Брокеры сообщений.Apache Kafka.WebHome]].
2 Основана на библиотеке [[librdkafka>>Разработка.Другое.C plus plus.Библиотеки.librdkafka.WebHome]].
3 | |(((
4 Варианты подключения потребителей:
5
6 * Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup.
7 * Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign. 
8 В таком случае ConsumerGroup не используется.
9 При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение.
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 ----