Комментарий

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

Подробности

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

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

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

Теги

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

Содержимое

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

XWiki.XWikiComments[0]

Автор

...	...	@@ -1,0 +1,1 @@
	1	+XWiki.cccc1808

Комментарий

...	...	@@ -1,0 +1,3 @@
	1	+Основной вариант использования ApacheKafka Сonsumer это режим подписки subscribe, при котором Kafka смостоятельно распределеяет партиции топика между потребителями.
	2	+
	3	+Но также есть возможность начать читать сообщения с любого смещения любой партиции через метод Assign. При этом ConsumerGroupId не будет задействована

Дата

...	...	@@ -1,0 +1,1 @@
	1	+2020-10-03 01:04:09.493