阿里云文档 2025-06-20

写入Kafka消息格式说明

本文介绍写入Kafka消息的消息结构及各字段含义。

问答 2024-07-31 来自:开发者社区

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段?

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到op before after字段?

问答 2024-06-15 来自:开发者社区

DTS是否支持将RDS MySQL表非主键字段作为Partition Key迁移到Kafka

DTS是否支持将RDS MySQL表非主键字段作为Partition Key迁移到Kafka

文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:flink1.16.0,sql-client客户端,报这个错,请问这个是什么问题啊? flink1.16.0,sql-client客户端,yarn-session下运行,报这个错,请问大佬这个是什么问题啊?怎么解决? ...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 参考回答: -...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
问答 2024-04-23 来自:开发者社区

Flink为什么我kafka 写到mysql的数据 字段对应关系变反了呢?

"Flink为什么我kafka 写到mysql的数据 字段对应关系变反了呢?kafka 是正常的 写到Mysql就变反了,我 FieldMapper使用的正常啊,没做kafka写的,用的是spark集成 "

问答 2024-04-22 来自:开发者社区

Flink CDC里binlogs日志读到kafka.每修改一次啊?

Flink CDC里binlogs日志读到kafka.每修改一次会读到3条日志,而且顺序可能不通,字段还有丢失是为啥?如果最后一条没有丢,数据正确,但是如果没丢的在前面,那么字段值就丢了。{"id":1,"long_txt_value":"d","name":"1","varchar_value":"9"}{"id":1,"long_txt_value":"d","name":"1"}{"id"....

问答 2024-02-25 来自:开发者社区

Flink因为源表的字段发生更改,请问对应的kafka topic,是否需要删掉重建呢?

Flink因为源表的字段发生更改,请问对应的kafka topic,是否需要删掉重建呢?

问答 2023-12-24 来自:开发者社区

Flink CDC中upsert-kafka作为数据源,如果加了字段,这个有什么好办法嘛?

Flink CDC中upsert-kafka作为数据源,如果加了字段,就不能从savepoint启动,不从savepoint 就只能从头消费,这样需要很长时间才能追上。这个有什么好办法嘛,目前我们都是再启动一个任务,追上之后再做切换?

问答 2023-12-24 来自:开发者社区

Flink CDC中mysql有个blob字段,是压缩后在写入的,这种怎么解析到kafka?

Flink CDC中mysql有个blob字段,是压缩后在写入的,这种怎么解析到kafka?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注