Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3953

start kafka fail

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Cannot Reproduce
    • 0.8.2.2
    • None
    • None
    • None
    • Linux host-172-28-0-3 3.10.0-327.18.2.el7.x86_64 #1 SMP Thu May 12 11:03:55 UTC 2016 x86_64 x86_64 x86_64 GNU/Linux

    Description

      kafka start fail. error messege:
      [2016-07-12 03:57:32,717] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
      java.util.NoSuchElementException: None.get
      at scala.None$.get(Option.scala:313)
      at scala.None$.get(Option.scala:311)
      at kafka.controller.KafkaController.clientId(KafkaController.scala:215)
      at kafka.controller.ControllerBrokerRequestBatch.<init>(ControllerChannelManager.scala:189)
      at kafka.controller.PartitionStateMachine.<init>(PartitionStateMachine.scala:48)
      at kafka.controller.KafkaController.<init>(KafkaController.scala:156)
      at kafka.server.KafkaServer.startup(KafkaServer.scala:148)
      at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:29)
      at kafka.Kafka$.main(Kafka.scala:72)
      at kafka.Kafka.main(Kafka.scala)
      [2016-07-12 03:57:33,124] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
      java.util.NoSuchElementException: None.get
      at scala.None$.get(Option.scala:313)
      at scala.None$.get(Option.scala:311)
      at kafka.controller.KafkaController.clientId(KafkaController.scala:215)
      at kafka.controller.ControllerBrokerRequestBatch.<init>(ControllerChannelManager.scala:189)
      at kafka.controller.PartitionStateMachine.<init>(PartitionStateMachine.scala:48)
      at kafka.controller.KafkaController.<init>(KafkaController.scala:156)
      at kafka.server.KafkaServer.startup(KafkaServer.scala:148)
      at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:29)
      at kafka.Kafka$.main(Kafka.scala:72)
      at kafka.Kafka.main(Kafka.scala)

      config:

      1. Generated by Apache Ambari. Tue Jul 12 03:18:02 2016

      authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
      auto.create.topics.enable=true
      auto.leader.rebalance.enable=true
      broker.id=0
      compression.type=producer
      controlled.shutdown.enable=true
      controlled.shutdown.max.retries=3
      controlled.shutdown.retry.backoff.ms=5000
      controller.message.queue.size=10
      controller.socket.timeout.ms=30000
      default.replication.factor=1
      delete.topic.enable=false
      external.kafka.metrics.exclude.prefix=kafka.network.RequestMetrics,kafka.server.DelayedOperationPurgatory,kafka.server.BrokerTopicMetrics.BytesRejectedPerSec
      external.kafka.metrics.include.prefix=kafka.network.RequestMetrics.ResponseQueueTimeMs.request.OffsetCommit.98percentile,kafka.network.RequestMetrics.ResponseQueueTimeMs.request.Offsets.95percentile,kafka.network.RequestMetrics.ResponseSendTimeMs.request.Fetch.95percentile,kafka.network.RequestMetrics.RequestsPerSec.request
      fetch.purgatory.purge.interval.requests=10000
      kafka.ganglia.metrics.group=kafka
      kafka.ganglia.metrics.host=localhost
      kafka.ganglia.metrics.port=8671
      kafka.ganglia.metrics.reporter.enabled=true
      kafka.metrics.reporters=
      kafka.timeline.metrics.host=
      kafka.timeline.metrics.maxRowCacheSize=10000
      kafka.timeline.metrics.port=
      kafka.timeline.metrics.reporter.enabled=true
      kafka.timeline.metrics.reporter.sendInterval=5900
      leader.imbalance.check.interval.seconds=300
      leader.imbalance.per.broker.percentage=10
      listeners=PLAINTEXT://host-172-28-0-3:6667
      log.cleanup.interval.mins=10
      log.dirs=/kafka-logs
      log.index.interval.bytes=4096
      log.index.size.max.bytes=10485760
      log.retention.bytes=-1
      log.retention.hours=168
      log.roll.hours=168
      log.segment.bytes=1073741824
      message.max.bytes=1000000
      min.insync.replicas=1
      num.io.threads=8
      num.network.threads=3
      num.partitions=1
      num.recovery.threads.per.data.dir=1
      num.replica.fetchers=1
      offset.metadata.max.bytes=4096
      offsets.commit.required.acks=-1
      offsets.commit.timeout.ms=5000
      offsets.load.buffer.size=5242880
      offsets.retention.check.interval.ms=600000
      offsets.retention.minutes=86400000
      offsets.topic.compression.codec=0
      offsets.topic.num.partitions=50
      offsets.topic.replication.factor=3
      offsets.topic.segment.bytes=104857600
      principal.to.local.class=kafka.security.auth.KerberosPrincipalToLocal
      producer.purgatory.purge.interval.requests=10000
      queued.max.requests=500
      replica.fetch.max.bytes=1048576
      replica.fetch.min.bytes=1
      replica.fetch.wait.max.ms=500
      replica.high.watermark.checkpoint.interval.ms=5000
      replica.lag.max.messages=4000
      replica.lag.time.max.ms=10000
      replica.socket.receive.buffer.bytes=65536
      replica.socket.timeout.ms=30000
      security.inter.broker.protocol=PLAINTEXTSASL
      socket.receive.buffer.bytes=102400
      socket.request.max.bytes=104857600
      socket.send.buffer.bytes=102400
      super.users=user:kafka
      zookeeper.connect=host-172-28-0-4:2181,host-172-28-0-2:2181,host-172-28-0-3:2181/kafka
      zookeeper.connection.timeout.ms=25000
      zookeeper.session.timeout.ms=30000
      zookeeper.sync.time.ms=2000

      Attachments

        Activity

          People

            Unassigned Unassigned
            ARunningPig ffh
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: