kafka.common.KafkaException: Failed to parse the broker info from zookeeper: 10.10.22.24-1435180967245:10.10.22.24:9092

flume-user | Mungeol Heo | 9 months ago
  1. 0

    Re: Are there source and sink for kafka 0.7?

    flume-user | 9 months ago | Mungeol Heo
    kafka.common.KafkaException: Failed to parse the broker info from zookeeper: 10.10.22.24-1435180967245:10.10.22.24:9092
  2. 0

    Re: Are there source and sink for kafka 0.7?

    flume-user | 9 months ago | Mungeol Heo
    kafka.common.KafkaException: Failed to parse the broker info from zookeeper: 10.10.22.24-1435180967245:10.10.22.24:9092
  3. 0

    [jira] [Commented] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

    mail-archive.com | 3 months ago
    kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1442952770627","endpoints":["PLAINTEXT://<host>:<plaintextport>","SSL://<host>:<sslport>"],"host”:”<host>","version":2,"port”:<port>}
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    2 unregistered visitors

    Root Cause Analysis

    1. kafka.common.BrokerNotAvailableException

      Broker id 19 does not exist

      at kafka.cluster.Broker$.createBroker()
    2. Apache Kafka
      ZkUtils$$anonfun$getCluster$1.apply
      1. kafka.cluster.Broker$.createBroker(Broker.scala:42)
      2. kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:506)
      3. kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:504)
      3 frames
    3. Scala
      AbstractIterable.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:727)
      2. scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
      3. scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
      4. scala.collection.AbstractIterable.foreach(Iterable.scala:54)
      4 frames
    4. Apache Kafka
      ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp
      1. kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:504)
      2. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:407)
      2 frames
    5. Scala
      Range.foreach$mVc$sp
      1. scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:141)
      1 frame
    6. Apache Kafka
      ZookeeperConsumerConnector.createMessageStreams
      1. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:402)
      2. kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:722)
      3. kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:212)
      4. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:80)
      5. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:92)
      5 frames
    7. org.apache.flume
      KafkaSource.start
      1. org.apache.flume.source.kafka.KafkaSource.start(KafkaSource.java:216)
      1 frame
    8. Flume
      LifecycleSupervisor$MonitorRunnable.run
      1. org.apache.flume.source.PollableSourceRunner.start(PollableSourceRunner.java:74)
      2. org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)
      2 frames
    9. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
      2. java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
      3. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
      4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
      5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      7. java.lang.Thread.run(Thread.java:745)
      7 frames