kafkaManager不能够正常监控kafka集群的问题修订版本明细

源

采纳

编辑于

无风三尺浪✅

kafkaManager不能够正常监控kafka集群的问题

kafka

kafkaManager不能够正常监控kafka集群的问题:

我三台集群zk和kafka都是正常启动

但是kafka不能够显示集群信息，kafkaManager抛了一个warn


kafka.common.KafkaException: Unknown group metadata version 3
        [warn] k.m.a.c.KafkaManagedOffsetCache - Failed to process a message from offset topic on cluster Kafka-Cluster-1!
kafka.common.KafkaException: Unknown group metadata version 3
        at kafka.manager.utils.one10.GroupMetadataManager$.schemaForGroup(GroupMetadataManager.scala:464) ~[kafka-manager.kafka-manager-1.3.3.22-sans-externalized.jar:na]
        at kafka.manager.utils.one10.GroupMetadataManager$.readGroupMessageValue(GroupMetadataManager.scala:607) ~[kafka-manager.kafka-manager-1.3.3.22-sans-externalized.jar:na]
        at kafka.manager.actor.cluster.KafkaManagedOffsetCache$$anonfun$run$4.apply(KafkaStateActor.scala:378) [kafka-manager.kafka-manager-1.3.3.22-sans-externalized.jar:na]
        at kafka.manager.actor.cluster.KafkaManagedOffsetCache$$anonfun$run$4.apply(KafkaStateActor.scala:326) [kafka-manager.kafka-manager-1.3.3.22-sans-externalized.jar:na]
        at scala.util.Success.foreach(Try.scala:236) [org.scala-lang.scala-library-2.11.12.jar:na]
        at kafka.manager.actor.cluster.KafkaManagedOffsetCache.run(KafkaStateActor.scala:326) [kafka-manager.kafka-manager-1.3.3.22-sans-externalized.jar:na]
        at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45]

预览