Как получить информацию о смещении потребителя Kafka в программе Flink - PullRequest
0 голосов
/ 19 января 2019

Я использую Flink's FlinkKafkaConsumer010 и Kafka версии 1.1.
Я хочу получить информацию о смещении задержки в моем коде

1 Ответ

0 голосов
/ 20 января 2019

Метрика коннектора Flink Kafka

commitOffsets: последние успешно зафиксированные смещения для Kafka для каждого раздела.Метрика конкретного раздела может быть указана по имени темы и идентификатору раздела.

currentOffsets: текущее смещение чтения потребителя для каждого раздела.Метрика конкретного раздела может быть указана по имени темы и идентификатору раздела.

...