Относительно 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. Все ок.
Почему я получаю эту ошибку?