kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1472124710146","endpoints":["PLAINTEXT://localhost:9092"],"host":"localhost","version":3,"port":9092}

GitHub | camelia-c | 6 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 1

    Copying connect-mongodb-1.0.jar vs. connect-mongodb-1.0-jar-with-dependencies.jar to $CONFLUENT_HOME/share/java/confluent-common - different issues

    GitHub | 6 months ago | camelia-c
    kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1472124710146","endpoints":["PLAINTEXT://localhost:9092"],"host":"localhost","version":3,"port":9092}

    1 unregistered visitors

    Root Cause Analysis

    1. java.lang.NoSuchMethodError

      org.apache.kafka.common.protocol.SecurityProtocol.forName(Ljava/lang/String;)Lorg/apache/kafka/common/protocol/SecurityProtocol;

      at kafka.cluster.EndPoint$.createEndPoint()
    2. Apache Kafka
      Broker$$anonfun$1.apply
      1. kafka.cluster.EndPoint$.createEndPoint(EndPoint.scala:49)
      2. kafka.cluster.Broker$$anonfun$1.apply(Broker.scala:90)
      3. kafka.cluster.Broker$$anonfun$1.apply(Broker.scala:89)
      3 frames
    3. Scala
      List.map
      1. scala.collection.immutable.List.map(List.scala:273)
      1 frame
    4. Apache Kafka
      ZkUtils$$anonfun$getAllBrokersInCluster$2.apply
      1. kafka.cluster.Broker$.createBroker(Broker.scala:89)
      2. kafka.utils.ZkUtils.getBrokerInfo(ZkUtils.scala:787)
      3. kafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:162)
      4. kafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:162)
      4 frames
    5. Scala
      AbstractTraversable.map
      1. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      2. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      3. scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
      4. scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
      5. scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
      6. scala.collection.AbstractTraversable.map(Traversable.scala:104)
      6 frames
    6. Apache Kafka
      ZkUtils.getAllBrokersInCluster
      1. kafka.utils.ZkUtils.getAllBrokersInCluster(ZkUtils.scala:162)
      1 frame
    7. io.confluent.kafka
      SchemaRegistryRestApplication.setupResources
      1. io.confluent.kafka.schemaregistry.storage.KafkaStore.<init>(KafkaStore.java:109)
      2. io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.<init>(KafkaSchemaRegistry.java:136)
      3. io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:53)
      4. io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:37)
      4 frames
    8. io.confluent.rest
      Application.createServer
      1. io.confluent.rest.Application.createServer(Application.java:117)
      1 frame
    9. io.confluent.kafka
      SchemaRegistryMain.main
      1. io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:43)
      1 frame