Como verificar as compensações do consumidor quando a loja offset é Kafka?

a partir da libertação de 0.8.1.1, o Kafka prevê o armazenamento de compensações no Kafka, em vez do guardião do Jardim zoológico (ver isto ). Eu não sou capaz de descobrir como verificar os detalhes das compensações consumidas, como as ferramentas atuais só fornecer cheques de contagem de compensação do consumidor apenas para o tratador de Zoológico.Estou a referir-me a isto.)

Se houver alguma ferramenta disponível para verificar a compensação do consumidor, por favor, avise-me.

Author: g33kb0ne, 2015-12-01

1 answers

Estou a usar kafka 0, 8.2 com compensações armazenadas em kafka. Estas ferramentas funcionam bem para mim:

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker 
        --topic your-topic 
        --group your-consumer-group
        --zookeeper localhost:2181

Você recebe todas as informações de que precisa: tamanho do tópico, atraso do consumidor, proprietário.

 3
Author: leshkin, 2017-04-25 08:41:13