开发者社区> 问答> 正文

Flink读取kafka没有报错也没有数据输出,Kafka消费端有数据,怎么解决?谢谢

我的环境是: 

| 组件 | 版本 |  |  Flink  |  1.12  |  |  Kafka  |  2.5.0  |  |  Zookeeper  |  3.6.0  | 

完整代码是  https://paste.ubuntu.com/p/pRWpvJw4b8/  kafka消费端(使用命令行消费)确认有数据输出。  但是上述代码没有输出,DDL检查过确认无误。 

因为听说executeSql会提交任务,所以把最后一句execute给注销了。  求问应该如何修改代码才能让代码有输出?  谢谢*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:47:11 1313 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载