开发者社区 问答 正文

同时发送两条消息至kafka

在canal-admin 下配置了一个集群 集群下部署了两台 server

创建了一个instance

消费kafka 消息时,是发现有每条消息都有 一条与之相同的数据,(id不一样,有时ts 不一样 )

当把一个server 停掉时,就只会收到一条唯一消息

请问是不是,每台server 都会处理相同的 binlog,导致会发相同的消息至 kafka 如何处理才能让两server 发送不同的 消息

原提问者GitHub用户ProLik

展开
收起
Java工程师 2023-05-03 10:32:18 86 分享 版权
1 条回答
写回答
取消 提交回答
  • binlog是顺序的,如果是集群模式同一时间点只有一个server和client工作

    原回答者GitHub用户agapple

    2023-05-04 14:35:21
    赞同 展开评论