Eu tenho um ambiente em que o logstash (v6.2.3) está conectando o cluster kafka_2.11 (v.1.1.0) usando a entrada kafka.
O que eu quero alcançar é buscar informações de compensação do consumidor usando kafka-consumer-group.sh . No entanto, acabo com erro abaixo.
[ywatanabe@centos74 kafka]$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group logstash --describe
OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N
Note: This will not show information about old Zookeeper-based consumers.
Error: Executing consumer group command failed due to null
Então agora estou diagnosticando esse problema primeiro acessando diretamente as informações da métrica usando jmxterm . O problema é que eu não entendo o que você precisa especificar para a atribuição.
$>info -b kafka.log:name=LogStartOffset,partition=2,topic=my-first-topic-1,type=Log
#mbean = kafka.log:name=LogStartOffset,partition=2,topic=my-first-topic-1,type=Log
#class name = com.yammer.metrics.reporting.JmxReporter$Gauge
# attributes
%0 - Value (java.lang.Object, r)
# operations
%0 - javax.management.ObjectName objectName()
#there's no notifications
O que exatamente você precisa especificar para Valor ?