Комментарий

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

Подробности

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

Теги

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

Содержимое

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

XWiki.XWikiComments[0]

Автор

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

Комментарий

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

Дата

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