Skip to content

关于canal 以事物为单位读取binlog后如何顺序的 发送到mq #5539

@mingzheng-git

Description

@mingzheng-git

Question

配置:
canal.mq.partitionHash = goleal_card\..*:$pk$
后是否意味着 读取到的事物会被分开发往mq?

如何在保障以事物为单位 在consumer被消费的同时保障:
一张表两次操作 insert 与update 有顺序的执行(避免一条记录还没有被 insert就提前执行了update

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions