ticdc在推送到kafka的时候,发现update是整条数据都推送的,是否可以设置只推送更新的那些字段?
当 sink 参数 only_output_updated_columns
设置为 true
时,old
字段仅包含被修改的列数据,你是要这个吗??
三部分:库表,事件,路由,好像没有到列这个层面,应该不支持吧
好像没有吧,就是不知道到kafka里面会不会有类型标识
对,是这个,感谢!
不过要注意以下点:该参数只有当下游为消息队列,并且使用 Open Protocol 或 Canal-JSON 时,才会生效。
此话题已在最后回复的 7 天后被自动关闭。不再允许新回复。