AI 助理
备案控制台
开发者社区 问答 正文

1.1.1版本kafka取出的json数据 缺少data字段 什么原因

1.1.1版本 kafka 取json数据，本地测试有data字段data:[{name:"abc"}]，canal连接linux上的数据库后 就没有data这个字段了 什么原因啊

是不是 只有delete和update语句才有 data字段 ，为什么insert没有呢

linux mysql为5.6版本 win为5.5

原提问者GitHub用户CodeLulu318

展开
收起
Java工程师 2023-05-08 17:52:07 151 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 函数计算小白

    flatMessage没有data数据？你用工程里的client-adapter接收打印一下dml信息看看是否正确

    有sql的说明是ddl操作 你可以清理一下position和mq的offset

    原回答者GitHub用户rewerma

    2023-05-09 18:45:13
    赞同 展开评论
问答分类：
消息中间件 canal JSON 关系型数据库 MySQL Kafka Linux 数据库 数据格式 云消息队列 Kafka 版 云数据库 RDS MySQL 版
问答标签：
JSON数据 云消息队列 Kafka 版数据 云消息队列 Kafka 版json JSON字段 JSON版本
问答地址：
开发者社区 > 数据库 > 问答
相关问答
flink sql输出到upsert kafka 下游再消费一般是upsert 还是 json呀？
69
0
0
flink kafka debezium-json读取更新的数据，没有op 怎么获取op为u的数据？
192
1
0
flinkcdcSQL处理Kafka数据，json数据是数组的，建表结构该怎么写？[{},{}]。？
77
0
0
kafka v2版本和v3版本的区别？
73
1
0
kafka写入的数据如果是json数组，可以批量写入到tablestore吗？
40
0
0
flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？
50
1
0
Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办？
70
0
0
有没有flink1.17版本，从kafka把数据写入到hbase的demo案例呢？
65
1
0
如何通过Kafka Connector解析嵌套JSON格式的数据
130
1
0
Flink CDC中flinksql怎么解析json数组[{},{}]格式数据？
130
1
0