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

canal 怎么过滤表的字段,比如我想剔除表里的某些字段,不发给后面kafka

canal 怎么过滤表的字段,比如我想剔除表里的某些字段,不发给后面kafka 原提问者GitHub用户Bruce2jiang

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

Kafka队列 使用FlatMessage怎么解析Mysql中的binary/varbinary字段

Kafka队列 使用FlatMessage怎么解析Mysql中的binary/varbinary字段中文或pb字符串乱码问题 原提问者GitHub用户YuanWeiKang

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

canal是否支持只订阅“特定记录中某几个字段的变化”的binlog日志,并将其写入到kafka、m

看到canal支持ElasticSearch适配器,在适配器表映射文件中配置sql映射,即可以把“特定记录中某几个字段的变化”写入到ES,想问下如果想把变化的数据写入到kafka或mq是否也支持sql的配置方式。 我的需求场景是,我只想订阅a表中记录对应b表中status字段的变化。a.id是唯一键,b.bid是主键 select a.id,b.status from a left join b....

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

canal上报kafka时,可以跳过大小超过定指定值的列吗?或跳过指定表的字段

canal上报kafka时,可以跳过大小超过定指定值的列吗?或跳过指定表的字段 原提问者GitHub用户jianghanfen

问答 2023-04-27 来自:开发者社区

canal 输出到kafka的json结构,各个字段的含义能说明一下吗

canal 输出到kafka的json结构,各个字段的含义能说明一下吗 原提问者GitHub用户chaixiaoxue

问答 2023-04-27 来自:开发者社区

canal写kafka时是否支持只请查阅mysql 表的指定字段 和指定记录

canal写kafka时,是否支持以下功能: 1, 若某表有10个字段, 只想往kafka里写其中5个字段,是否支持? 2, 同步某表数据时,是否支持自定义sql,如只想往kafka里写type=1的记录 原提问者GitHub用户liminghuid

问答 2023-04-26 来自:开发者社区

这个op字段能获取到吗?我消费kafka时加上了sql-type这个元数据字段,但是查询出来是个nu

这个op字段能获取到吗?我消费kafka时加上了sql-type这个元数据字段,但是查询出来是个null是怎么回事呢

问答 2023-03-20 来自:开发者社区

大佬们,cdc ddl怎么写能把op 字段给带出来?我想写到Kafka里面。

大佬们,cdc ddl怎么写能把op 字段给带出来?我想写到Kafka里面。

问答 2023-02-06 来自:开发者社区

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

问答 2023-01-04 来自:开发者社区

这个Kafka中的json数据有些复杂,并且有的字段key存在多个,而且key的命名也不是很规范,例

这个Kafka中的json数据有些复杂,并且有的字段key存在多个,而且key的命名也不是很规范,例如有的key前面是个“$”,这样的我可以直接映射成Flink 表吗,或者说我这个映射的对不对? 

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

产品推荐

消息队列

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

+关注