Назад | Перейти на главную страницу

Какой атрибут нужно указать для метрики смещения начала журнала kafka?

У меня есть среда, в которой logstash (v6.2.3) подключает кластер kafka_2.11 (v.1.1.0) с использованием ввода kafka.

Я хочу получить информацию о смещении потребителя, используя kafka-consumer-group.sh . Однако я получаю ошибку ниже.

[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

Итак, теперь я сначала диагностирую эту проблему, напрямую обращаясь к метрической информации, используя jmxterm. Проблема в том, что я не понимаю, что вам нужно указать для атрибута.

$>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

Что именно нужно указать для Стоимость ?