flinksql读取kafka数据报错
flinksql创建kafka的表成功了，但是在查询的时候报错
报错信息如下：
网络是通的，
kafka版本：kafka_2.12-3.1.0
flink版本：flink-1.14.4
使用的flink-sql-connector-kafka jar包是：flink-sql-connector-kafka_2.11-1.14.4.jar
一直在想是不是jar包不匹配的问题，报错信息看不出来是jar包问题
请帮忙
flinksql读取kafka数据报错
网络是通的，
kafka版本：kafka_2.12-3.1.0
flink版本：flink-1.14.4
使用的flink-sql-connector-kafka jar包是：flink-sql-connector-kafka_2.11-1.14.4.jar
一直在想是不是jar包不匹配的问题，报错信息看不出来是jar包问题
请帮忙
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
3条回答 默认 最新
三千烦恼丝xzh 2022-07-14 08:03关注restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 分享
- 2024-07-21 18:22一切如来心秘密的博客 本文总结了如何使用使用 Clickhouse ...本文设计到的技能知识点比较多，需要熟悉 Clickhouse， Kafka, FlinkSQL, Superset 等，我之前的文章中总结了一些关于 Clickhouse 和 Kafka 相关的内容，感兴趣的读者可以看看.
- 2022-11-03 10:33Xiaobai on data 开发的博客 FlinkSql写入/读取Kafka
- 2024-11-25 11:36倾一生爱恋换一世纯真的博客 【代码】FLinkSQL写法kafka关联MySQL写入MySQL（proctime）
- 2024-02-06 20:45一杯咖啡半杯糖的博客 本博客在sql-client中模拟大数据平台的sql编辑器执行FlinkSQL,使用Flink实现数据从Kafka传输到MySQL具体操作，这个在生产开发中比较常用，通常生产用kafka作为数据的输入，本例子Flink版本1.13.6，具体操作如下：
- 王知无(import_bigdata)的博客 《2021年最新版大数据面试题全面开启更新》 版本说明： Flink 1.11.2 Kafka 2.4.0 Hive3.1.2 Hadoop 3.1.3 1 hive 安装hive，使用mysql做为元数据存储 1.2 hive-site.xml 配置 （版本3.1.2） <?xml ...
- 2024-01-31 12:21Laurence 的博客 本问题发生的场景是：使用 Kafka Connect 的 Debezium MySQL Source Connector 将 MySQL 的 CDC 数据 （Confluent Avro 格式）接入到 Kafka 之后，通过 Flink 读取并解析这些 CDC 数据，然后写入到 Hudi 表中。...
- 星光璀璨下的梦幻舞台的博客 在使用Flink读取Kafka时，遇到报错信息"KafkaException ByteArrayDeserializer is not an instance Deserializer"是因为反序列化器与实际消息的格式不匹配。为了解决这个问题，我们需要确保在Flink的Kafka消费者配置...
- 2021-01-09 07:03乔木 Leo的博客 SQL 语句创建 Kafka 数据源，这极大的方便了用户开发 Flink 实时任务，你可以像 Hive 一样，使用 Create Table 语句来创建 Kafka Source，同时在也可以使用 Select 语句，从这个表中读取数据，进行窗口、ETL等操作。...
- 2022-08-29 10:59fyl005的博客 当有数据到来时，会有报错信息，从报错信息中可以看到 topic 中的数据格式。
- 2023-08-17 00:40rookiewpj的博客 这个依赖,还加了多余的kafkaclient依赖;
- 没有解决我的问题, 去提问
问题事件
系统已结题
7月22日
已采纳回答
7月14日-
赞助了问题酬金10元
7月14日
-
创建了问题
7月13日