En cuanto a Apache-Kafka messaging queue.kafka NoClassDefFoundError kafka/Kafka
He descargado Apache Kafka desde la página de descarga de Kafka. Lo he extraído a /opt/apache/installed/kafka-0.7.0-incubating-src
.
El quickstart page dice que necesita para empezar empleado del zoológico y luego empezar a Kafka ejecutando: >bin/kafka-server-start.sh config/server.properties
estoy usando un servidor Zookeeper por separado, por lo que he editado config/server.properties
para apuntar a esa instancia Zookeeper.
Cuando corro Kafka, como se indica en la página de inicio rápido, me sale el siguiente error:
Exception in thread "main" java.lang.NoClassDefFoundError: kafka/Kafka
Caused by: java.lang.ClassNotFoundException: kafka.Kafka
at java.net.URLClassLoader$1.run(URLClassLoader.java:200)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)
Could not find the main class: kafka.Kafka. Program will exit.
que utiliza telnet para asegurarse de que la instancia Zookeeper es accesible desde la máquina que se ejecuta en Kafka. Todo está bien.
¿Por qué me sale este error?
Esta pregunta fue hecha hace 4 años. En ese momento, la opción del código fuente era la única opción. – summerbulb