java - Kafka 流 API 示例 KStream 无法解析为类型

Question

我正在学习这个 Kafka 流教程

https://kafka.apache.org/0110/documentation/streams/tutorial

在运行 JRE 8+ 和 Kafka 0.11.0.1 的 Centos 7 机器上

这是抛出编译错误的行

KStream<String, String> source = builder.stream("streams-plaintext-input");

尝试编译 LineSplit 示例时出现 Java 异常

KStream cannot be resolved to a type

作为一个 Java 菜鸟，我不确定如何解决这个问题。仔细检查进口报关单，甚至复制粘贴样本也是徒劳。

任何关于如何解决这个问题的线索都非常感谢。

Answer 1

请阅读有关 Java 的教程。 (另外请编辑您的问题以包括整个代码以及您如何编译它。)

你需要确保

• 在您的代码中导入所有必需的类
• 为编译器提供相应的库

我建议使用 IDEA(如 Intellij 或 Eclipse)并使用构建工具，如 maven 或 gradle。

本教程展示了如何为您的 Kafka Streams 项目设置 Maven 项目:http://kafka.apache.org/0110/documentation/streams/tutorial