版本

U10SPC005 kafka

问题描述

kafka单broker故障，提示异常如下：

2019-07-27 17:03:35,121 | INFO  | [main] | Registered broker 4 at path /brokers/ids/4 with addresses: SASL_PLAINTEXT -> EndPoint(10.34.151.157,21007,SASL_PLAINTEXT),PLAINTEXT -> EndPoint(10.34.151.157,21005,PLAINTEXT),SSL -> EndPoint(10.34.151.157,21008,SSL),SASL_SSL -> EndPoint(10.34.151.157,21009,SASL_SSL) | kafka.utils.ZkUtils (Logging.scala:68) 
2019-07-27 17:03:35,122 | ERROR | [main] | Failed to read meta.properties file under dir /srv/BigData/kafka/data1/kafka-logs/meta.properties due to requirement failed: Missing required property 'version' | kafka.server.BrokerMetadataCheckpoint (Logging.scala:97) 
2019-07-27 17:03:35,123 | FATAL | [main] | [Kafka Server 4], Fatal error during KafkaServer startup. Prepare to shutdown | kafka.server.KafkaServer (Logging.scala:116) 
java.lang.IllegalArgumentException: requirement failed: Missing required property 'version'
    at scala.Predef$.require(Predef.scala:233)
    at kafka.utils.VerifiableProperties.getIntInRange(VerifiableProperties.scala:47)
    at kafka.server.BrokerMetadataCheckpoint.liftedTree2$1(BrokerMetadataCheckpoint.scala:59)
    at kafka.server.BrokerMetadataCheckpoint.read(BrokerMetadataCheckpoint.scala:57)
    at kafka.server.KafkaServer$$anonfun$checkpointBrokerId$1.apply(KafkaServer.scala:687)
    at kafka.server.KafkaServer$$anonfun$checkpointBrokerId$1.apply(KafkaServer.scala:686)
    at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
    at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
    at kafka.server.KafkaServer.checkpointBrokerId(KafkaServer.scala:686)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:266)
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
    at kafka.Kafka$.main(Kafka.scala:67)
    at kafka.Kafka.main(Kafka.scala)

分析过程

1.对比这个文件/srv/BigData/kafka/data1/kafka-logs/meta.properties