Apache Kafka Java类？

Question

我试图用Java程序导入kafka类,我找不到我需要导入的Java类,例如:

import kafka.message.Message;
import kafka.utils.Utils;

谁能告诉我在哪里可以找到这些Java类以及如何提供它们？在我看来,Kafka是用Scala编写的,所以在下载源代码后我找不到那些java类.

Answer 1

如果您还没有使用以下内容,首先需要构建Kafka版本:


`tar xzf kafka-[VERSION].tgz`
`cd kafka-[VERSION]`
`./sbt update`
`./sbt package`

最简单的方法是将生成的kafka- [VERSION] .jar(在kafka-0.7.2-incubating-src/core/target/scala_2.8.0 /中)和其他所需的依赖项放在构建路径上它应该工作.

所有依赖项(在kafka- [VERSION] -incubating-src/core/lib_managed/scala_2.8.0/compile /)都使用sbt update解析.