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>}

mail-archive.com | 3 months ago
  1. 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>}
  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

    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
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Embeded Kafka server down and may not be restarted

    Google Groups | 6 months ago | Fredrik
    kafka.common.KafkaException: fetching topic metadata for topics [Set(metrics)] from broker [ArrayBuffer(id:0,host:<NODE_NAME>,port:9092)] failed > at kafka.client.ClientUtils$.fetc hTopicMetadata(ClientUtils.scala:72) > at kafka.producer.BrokerPartition Info.updateInfo(BrokerPartitionInfo.scala:82) > at kafka.producer.async.DefaultEv entHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandl er.scala:78)
  6. 0

    GitHub comment 48#32771562

    GitHub | 3 years ago | junrao
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker > [ArrayBuffer(id:0,host:192.168.195.177,port:9092)] failed

    2 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. 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>}

      at kafka.cluster.Broker$.createBroker()
    2. Apache Kafka
      ZkUtils$$anonfun$getCluster$1.apply
      1. kafka.cluster.Broker$.createBroker(Broker.scala:61)
      2. kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:520)
      3. kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:518)
      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
      ZkUtils$.getCluster
      1. kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:518)
      1 frame