Комментарий

• Свойства страницы (2 изменено, 0 добавлено, 0 удалено)
• Объекты (0 изменено, 0 добавлено, 1 удалено)
  • XWiki.XWikiComments[0]

Подробности

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

Родительский документ

...	...	@@ -1,1 +1,1 @@
1		-Разработка.NET.Библиотеки.Провайдеры.Брокеры сообщений.WebHome
	1	+Разработка.NET.Работа с брокерами сообщений.WebHome

Содержимое

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