Когда kafka-consumer-groups.sh показывает CURRENT_OFFSET как "-"? - PullRequest
0 голосов
/ 12 июня 2018

Что означает, что в столбце CURRENT-OFFSET отображается "-"?

TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                        HOST            CLIENT-ID
events          6          -               4021552         -               stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
events          2          -               7056462         -               stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
events          12         3143580         11052506        7908926         stream-processor-975c-StreamThread-1-consumer-d6f1 /my.ip  stream-processor-975c-StreamThread-1-consumer
... several other entries, some with and some without "-"

Что может привести к такому сценарию и что это значит для потребителей?

Я запускаю приложение KafkaStreams по этой теме (16 разделов) с 3 экземплярами, по одному потоку в каждом.У меня недавно произошел сбой двух узлов, и в этой теме репликация = 2, поэтому некоторые разделы некоторое время оставались без лидера.

Как разделы в этом состоянии влияют на обычного потребителя или приложение Kafka Streams

1 Ответ

0 голосов
/ 12 июня 2018

Если потребитель еще не зафиксировал свои смещения, вы увидите тире -, означающую недоступность.По той же причине задержка не может быть вычислена и показывает -.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...