Hi wchxii, 你说的没错,我在Java中错误地import了scala的StreamExecutionEnvironment ,问题已解决!感谢!
Best, Nat 在2020年10月30日 14:56,wch...@163.com<wch...@163.com> 写道: 在使用java时, StreamExecutionEnvironment 使用 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment这个完全限定名的类, 你这里应该是导入了org.apache.flink.streaming.api.scala.StreamExecutionEnvironment wch...@163.com 发件人: Natasha 发送时间: 2020-10-30 10:19 收件人: user-zh@flink.apache.org 主题: Flink程序连接Kafka类型不匹配问题 Hi,社区~ 我想把Flink连接Kafka封装成通用的方法,但是在使用java时,类型转换上遇到了问题,这个问题网上搜索到的资料很少,刚入门不久所以也不是很明白其中的原理,请各位同行指点我一下,不胜感激。 Best, Nat