我正在通过此卡夫卡流教程工作

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新手,我不确定如何解决此问题。仔细检查了进口申报单,甚至徒劳地将 sample 复制粘贴了。

任何有关如何解决此问题的线索都值得赞赏。

最佳答案

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

您需要确保

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

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

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

    关于java - Kafka Streams API示例KStream无法解析为一种类型,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46678251/

    10-12 22:27