我正在通过此卡夫卡流教程工作
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/