这是函数式接口。。应该用lambda替代就行了 发件人: Natasha [mailto:[email protected]] 发送时间: 2020年10月30日 星期五 10:19 收件人: [email protected] 主题: Flink程序连接Kafka类型不匹配问题
Hi,社区~
我想把Flink连接Kafka封装成通用的方法,但是在使用java时,类型转换上遇到了问题,这个问题网上搜索到的资料很少,刚入门不久所以也不是很明白其中的原理,请各位同行指点我一下,不胜感激。
[cid:[email protected]]
Best,
Nat
