noclassdeffounderror - kafka NoClassDefFoundError kafka/Kafka

Question

关于Apache-Kafka messaging queue .

我已经从 Kafka 下载页面下载了 Apache Kafka。我已将其提取到 /opt/apache/installed/kafka-0.7.0-incubating-src。

quickstart page说你需要启动zookeeper，然后通过运行启动Kafka:
>bin/kafka-server-start.sh config/server.properties

我使用单独的 Zookeeper 服务器，因此我编辑了 config/server.properties 以指向该 Zookeeper 实例。

当我按照快速入门页面中的说明运行 Kafka 时，出现以下错误:

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.

我使用 telnet 来确保可以从运行 Kafka 的计算机访问 Zookeeper 实例。一切都好。

为什么我会收到此错误？

Answer 1

您必须首先通过运行以下命令构建 Kafka:

> ./sbt update
> ./sbt package 

只有这样，Kafka 才可以使用。