org.apache.kafka.common.KafkaException

If you like a tip written by other Samebug users, mark is as helpful! Marks help our algorithm provide you better solutions and also help other users.
tip

This might be an issue with the file location in the Spark submit command. Try it with "spark-submit --master spark://master:7077 hello_world_from_pyspark.py {file location}"

tip

Check if you've set a name in Application -> Run. If you didn't, the generated XML is gonna have missing information and then this exception will be thrown.

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

  • ClassNotFoundException while transforming XML
    via Stack Overflow by Hendrik
    ,
  • Glassfish 3.1.2 OSE on IBM J9 JVM
    via by petino,
  • Re: ZooInspector on Mac OS X
    via by Kevin Gao,
  • Error in spark-submit but not in pyspark
    via Stack Overflow by nanounanue
    ,
    • org.apache.kafka.common.KafkaException: Failed to construct kafka consumer at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:518) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:500) at com.ibm.streamsx.messaging.kafka.KafkaConsumerV9.<init>(KafkaConsumerV9.java:29) at com.ibm.streamsx.messaging.kafka.KafkaStringConsumerV9.<init>(KafkaStringConsumerV9.java:12) at com.ibm.streamsx.messaging.kafka.KafkaConsumerFactory.getClient(KafkaConsumerFactory.java:27) at com.ibm.streamsx.messaging.kafka.KafkaSource.allPortsReady(KafkaSource.java:116) at com.ibm.streams.operator.internal.runtime.api.OperatorAdapter.allPortsReady(OperatorAdapter.java:763) at com.ibm.streams.operator.internal.jni.JNIBridge.allPortsReady(JNIBridge.java:614) Caused by: org.apache.kafka.common.KafkaException: roundrobin ClassNotFoundException exception occured at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:204) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:566) ... 8 more Caused by: java.lang.ClassNotFoundException: roundrobin at java.lang.Class.forNameImpl(Native Method) at java.lang.Class.forName(Class.java:321) at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:328) at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:202) ... 9 more

    Users with the same issue

    zsamboki
    1 times, last one,
    Pilleo
    2 times, last one,
    kimihanif
    1 times, last one,
    Unknown visitor1 times, last one,
    SteVio1989
    2 times, last one,
    303 more bugmates