回复： Flink程序连接Kafka类型不匹配问题

Thu, 29 Oct 2020 20:27:31 -0700 

Hi Admin,
    你说的没错，我错误地import了scala的DataStream，问题已解决！感谢！






Best,
Nat
在2020年10月30日 11:06，admin<[email protected]> 写道：
Hi，
怀疑你import了scala的包，把import部分也贴出来看看呢

2020年10月30日 上午10:19，Natasha <[email protected]> 写道：

Hi,社区~
我想把Flink连接Kafka封装成通用的方法，但是在使用java时，类型转换上遇到了问题，这个问题网上搜索到的资料很少，刚入门不久所以也不是很明白其中的原理，请各位同行指点我一下，不胜感激。
<CA342559-CDB5-4DD4-8760-0FA2EE88E276.png>
Best,
Nat

回复