开发者社区> 问答> 正文

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

我想把Flink连接Kafka封装成通用的方法,但是在使用java时,类型转换上遇到了问题,这个问题网上搜索到的资料很少,刚入门不久所以也不是很明白其中的原理,请各位同行指点我一下,不胜感激。*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 11:57:33 1212 0
1 条回答
写回答
取消 提交回答
  • 对的是我!

    这是函数式接口。。应该用lambda替代就行了*来自志愿者整理的flink邮件归档

    2021-12-08 17:02:11
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载