運行Kafka hadoop-consumer時出現ClassNotFoundException

Question

我是Kafka的新手，我正在測試hortonworks sanbox 2.3。我正在關注kafka教程 https://github.com/kafka-dev/kafka/tree/master/contrib/hadoop-consumer。

當運行./run-class.sh kafka.etl.impl.DataGenerator 測試/ test.properties，我得到錯誤

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/conf/Configuration 
     at java.lang.Class.getDeclaredMethods0(Native Method) 
     at java.lang.Class.privateGetDeclaredMethods(Class.java:2615) 
     at java.lang.Class.getMethod0(Class.java:2856) 
     at java.lang.Class.getMethod(Class.java:1668) 
     at sun.launcher.LauncherHelper.getMainMethod(LauncherHelper.java:494) 
     at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:486) Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.conf.Configuration 
     at java.net.URLClassLoader$1.run(URLClassLoader.java:366) 
     at java.net.URLClassLoader$1.run(URLClassLoader.java:355) 
     at java.security.AccessController.doPrivileged(Native Method) 
     at java.net.URLClassLoader.findClass(URLClassLoader.java:354) 
     at java.lang.ClassLoader.loadClass(ClassLoader.java:425) 
     at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) 
     at java.lang.ClassLoader.loadClass(ClassLoader.java:358) 
     ... 6 more 

我已經包括run-class.sh所有可能的卡夫卡罐子但仍然沒有運氣。請幫忙！

Answer 1

你缺少罐子類org.apache.hadoop.conf.Configuration這不是卡夫卡庫的一部分。它應該包含在hadoop-common-2.5.0中。您必須將此jar添加到類路徑中。