☰

您需要为 kafka 日志起始偏移量指标指定什么属性？

tag-icon • tag-icon linux kafka
您需要为 kafka 日志起始偏移量指标指定什么属性？

我有一个环境，其中 logstash（v6.2.3）正在使用 kafka 输入连接 kafka_2.11 集群（v.1.1.0）。

我想要实现的是使用以下方法获取消费者偏移信息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

因此，我现在首先通过使用以下方式直接访问度量信息来诊断此问题论坛。问题是，我不明白您需要为属性指定什么。

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

你到底需要指定什么价值？

相关内容