Изменения документа Получение данных о смещении

Сводка

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

Подробности

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

Название

...	...	@@ -1,1 +1,1 @@
1		-Задача. Получение данных о смещении
	1	+Получение данных о смещении

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

...	...	@@ -1,1 +1,1 @@
1		-Разработка.NET.Работа с брокерами сообщений.Confluentinc\.Confluent-kafka-dotnet.WebHome
	1	+Разработка.NET.Работа с брокерами сообщений.Confluentinc\. Confluent-kafka-dotnet.Сценарии.WebHome

Содержимое

...	...	@@ -1,22 +1,23 @@
	1	+|Задание:
	2	+Получение информации о текущем состоянии параметров:(((
	3	+1. Общее кол-во сообщений в topic
	4	+1. Общее кол-во прочитанных(commited) сообщений в topic (по определенной consumerGroup)
	5	+1. Определение общего значения lag в topic(Разность между общей длиной и кол-во прочитанных сообщений) (по определенной consumerGroup)
1	1
2		-Задание:
3		-Получение ифнормации о текущем состоянии параметров:
4		-1) Общее кол-во сообщений в topic
5		-2) Общее кол-во прочитанных(commited) сообщений в topic (по определенной consumerGroup)
6		-3) Определение общего значения lag в topic(Разность между общей длиной и кол-во прочитанных сообщений) (по определенной consumerGroup)
7	7	Опционально по каждому partition.
8		-Данные по topic можно определить по сумме совокупности данных по каждом partition, принажлежащему данному topic.
9		-
	8	+Данные по topic можно определить по сумме совокупности данных по каждом partition, принадлежащему данному topic.
	9	+)))
	10	+|(((
	11	+Get Consumer lag using LibrdkafkaHandle.OutQueueLength
10	10	https://github.com/confluentinc/confluent-kafka-dotnet/issues/1161
11		-https://stackoverflow.com/questions/57302244/aug-2019-kafka-consumer-lag-programmatically
12	12
13		-
14		-Решение:
	14	+Aug 2019 - Kafka Consumer Lag programmatically
	15	+https://stackoverflow.com/questions/57302244/aug-2019-kafka-consumer-lag-programmatically
	16	+)))
	17	+|Решение:
15	15	Данные по общему кол-ву сообщений и прочитанным сообщениям можно получить через Consumer. Причем для указанного partition.
16	16	Данные по topic формируются через сумму данных всех partitions, входящих в него.
17		-
18		-{{code language="c#"}}
19		- //номер смещения последнего сообщения в очереди
	20	+|{{code language="c#"}} //номер смещения последнего сообщения в очереди
20	20	consumer
21	21	.QueryWatermarkOffsets(TopicPartitionInfo(topicName, partitionId),ConnectionParamsEntity.ActionTimeout)
22	22	.High
...	...	@@ -29,5 +29,4 @@
29	29	)
30	30	.FirstOrDefault()
31	31	.Offset
32		- .Value;
33		-{{/code}}
	33	+ .Value;{{/code}}