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

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

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

问答 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"....

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

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

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

问答 2023-07-13 来自:开发者社区

Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?

问题1:Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?问题2:不能用debezium-json格式拿op字段数据吗

问答 2023-05-30 来自:开发者社区

大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段,这个该如何解决?

问题1:大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? 我也纳闷怎么到了Kafka 就变成了字符串 问题2:utf8

问答 2023-05-29 来自:开发者社区

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段数据和MySQL的不一致?

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? debezium的参数配置

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

产品推荐

消息队列

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

+关注