Комментарий

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

Подробности

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

Название

...	...	@@ -1,1 +1,1 @@
1		-Confluentinc. Confluent-kafka-dotnet
	1	+Confluentinc.Confluent-kafka-dotnet

Теги

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

Содержимое

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