java - 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 更新解决。

您可以按照 http://kafka.apache.org/07/quickstart.html 中的步骤操作