TiCDC 把数据同步到 Kafka 时,一个事务内的多次变更,能不能发到kafka是多条消息。比如一个事务有3次变更,对应kafka是3条消息。
protocol用的是canal
期待大佬们的答复,非常感谢!
TiCDC 把数据同步到 Kafka 时,一个事务内的多次变更,能不能发到kafka是多条消息。比如一个事务有3次变更,对应kafka是3条消息。
protocol用的是canal
期待大佬们的答复,非常感谢!
一个事务内的 只提交一次,可以看到最后的结果
同一个事务,最后提交应该只会产生一个log,推送到kafka也会是一个消息。要不就违背了事务的acid
多次变更,你想体现出来,应该是多次事务…