Комментарий

• Свойства страницы (2 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Теги

...	...	@@ -1,0 +1,1 @@
	1	+Apache|ApacheKafka|БрокерСообщений|Провайдер

Содержимое

...	...	@@ -1,36 +1,16 @@
1		-| |Библиотека для работы с [[Apache Kafka>>Разработка.Брокеры сообщений.Apache Kafka.WebHome]].
	1	+Библиотека для работы с [[Apache Kafka>>Разработка.Брокеры сообщений.Apache Kafka.WebHome]].
2	2	Основана на библиотеке [[librdkafka>>Разработка.Другое.C plus plus.Библиотеки.librdkafka.WebHome]].
3		-| |(((
4		-Варианты подключения потребителей:
5	5
6		-* Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup.
7		-* Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign.
8		-В таком случае ConsumerGroup не используется.
9		-При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение.
10		-Подход может быть использован для повторного излечения уже прочитанных ранее сообщений.
11		-)))
12		-| |
13		-
14	14	----
15	15
16		-==== Внутренние ссылки: ====
17		-
18		-====== Дочерние страницы: ======
19		-
20	20	{{children/}}
21	21
22		-====== Обратные ссылки: ======
	8	+----
23	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}}
	10	+Варианты подключения потребителей:
35	35
36		-----
	12	+* Основной вариант использования ApacheKafka, когда клиент-потребитель (Сonsumer) использует режим подписки (subscribe), при котором Kafka самостоятельно распределяет партиции топика между потребителями с учетом смещения (offset) его ConsumerGroup.
	13	+* Есть возможность прочитать любое сообщение, которое на данный момент находится в топике, указав его идентификатор - <TopicName>.<PartitionId>.<Offset>. Для используется метод Assign.
	14	+В таком случае ConsumerGroup не используется.
	15	+При таком подходе задача по контролю распределения Partition-Consumer, и задача по управлению смещением, ложатся на клиентское приложение.
	16	+Подход может быть использован для повторного излечения уже прочитанных ранее сообщений.