kafka NoClassDefFoundError kafka/Kafka

Относительно Apache -Очередь сообщений Kafka .

Я скачал Apache Kafka со страницы загрузки Kafka. Я извлек его в /opt/apache/installed/kafka-0.7.0-incubating-src.

На странице быстрого запуска говорится, что вам нужно запустить 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, чтобы убедиться, что экземпляр Zookeeper доступен с компьютера, на котором работает Kafka. Все ок.

Почему я получаю эту ошибку?

12
задан Charles 4 May 2012 в 20:08
поделиться