0

我下载了包含 camus jar 的 confluent 包，并按照在线说明在此处输入链接描述。

Hadoop 设置正确（这意味着我可以使用 hadoop fs -ls 命令和其他 hadoop jar 命令）。但是，当我尝试运行时

hadoop jar confluent-camus-1.0.jar com.linkedin.camus.etl.kafka.CamusJob

我收到“主”类未发现错误

Exception in thread "main" java.lang.ClassNotFoundException: com.linkedin.camus.
etl.kafka.CamusJob
        at java.net.URLClassLoader$1.run(URLClassLoader.java:372)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:360)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:344)
        at org.apache.hadoop.util.RunJar.main(RunJar.java:205)

“confluent-camus-1.0.jar”的路径是正确的（就在文件夹下面）。我没有启动kafka服务，只是为了尝试运行它。

有人遇到过类似的问题吗？

谢谢。

4

1 回答 1

0

您应该尝试检查您的 jar 文件：

jar tvf confluent-camus-1.0.jar | grep com.linkedin.camus.etl.kafka.CamusJob

如果没有找到这个类，请尝试在camus生成的其他jar中找到它。

在你应该添加目标jar之后

hadoop jar confluent-camus-1.0.jar com.linkedin.camus.etl.kafka.CamusJob -libjars {JAR_NAME}
于 2015-09-23T10:28:43.103 回答