java.lang.ClassCastException：クラスcom.airbnb.kafka.kafka08.StatsdMetricsReporter

Question

statsdを使用してKafkaクラスタの監視システムを設定する作業を行います。私はstatsdライブラリhereを使用しています。現在、私のブローカーサーバーは起動しません。

私の肯定的な意見は、私のserver.propertiesファイル内のこの設定行にあります：metric.reporters=com.airbnb.kafka.kafka08.StatsdMetricsReporterです。

私はその行をコメントアウトすると、サーバーが起動します。地獄、私もこのようstatsd確認を得る：

しかし、統計が報告されていない

[2017-06-06 15:19:35,669] INFO Reporter is enabled and starting... (com.airbnb.metrics.StatsDReporter) 
[2017-06-06 15:19:35,679] INFO Started Reporter with host=localhost, port=8125, polling_period_secs=10, prefix= (com.airbnb.metrics.StatsDReporter) 

（私は信じている）、これも本当ですので：metric.reporters = []。そのため、問題の原因となっている行がプロパティファイルに存在する必要があります。

私は、サーバーを起動しようとすると、それはこのメッセージで失敗します。レコードの

[2017-06-06 15:21:34,712] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) 
java.lang.ClassCastException: class com.airbnb.kafka.kafka08.StatsdMetricsReporter 
    at java.lang.Class.asSubclass(Class.java:3404) 
    at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:356) 
    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:243) 
    at kafka.server.KafkaServer.startup(KafkaServer.scala:198) 
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39) 
    at kafka.Kafka$.main(Kafka.scala:67) 
    at kafka.Kafka.main(Kafka.scala) 
[2017-06-06 15:21:34,713] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer) 
[2017-06-06 15:21:34,714] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) 
[2017-06-06 15:21:34,718] INFO Session: 0x15c7ed717e30004 closed (org.apache.zookeeper.ZooKeeper) 
[2017-06-06 15:21:34,720] INFO EventThread shut down for session: 0x15c7ed717e30004 (org.apache.zookeeper.ClientCnxn) 
[2017-06-06 15:21:34,720] INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer) 
[2017-06-06 15:21:34,720] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable) 
java.lang.ClassCastException: class com.airbnb.kafka.kafka08.StatsdMetricsReporter 
    at java.lang.Class.asSubclass(Class.java:3404) 
    at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:356) 
    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:243) 
    at kafka.server.KafkaServer.startup(KafkaServer.scala:198) 
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39) 
    at kafka.Kafka$.main(Kafka.scala:67) 
    at kafka.Kafka.main(Kafka.scala) 
[2017-06-06 15:21:34,721] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer) 

は、ここに私の設定です：

kafka:type=com.airbnb.kafka.kafka08.StatsdMetricsReporter 
metric.reporters=com.airbnb.kafka.kafka08.StatsdMetricsReporter 
kafka.metric.reporters=com.airbnb.kafka.kafka08.StatsdMetricsReporter 
external.kafka.statsd.reporter.enabled=true 
external.kafka.statsd.host=localhost 
external.kafka.statsd.port=8125 
external.kafka.statsd.metrics.prefix= 
external.kafka.statsd.tag.enabled=true 

Answer 1

私は答えを見つけました。 kafka08の代わりにkafka09を使用しなければなりませんでした。