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

Kafka streams API sample KStream cannot be resolved to a type

我正在学习这个 Kafka 流教程

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

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

这是抛出编译错误的行

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

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

KStream cannot be resolved to a type

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

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

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

您需要确保

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

我建议使用 IDEA（如 Intellij 或 Eclipse）并使用像 maven 或 gradle 这样的构建工具。

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