Комментарий

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

Подробности

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

Содержимое

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

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