开发者社区> 问答> 正文

update 整张表后无限循环报错 no match ack positionLogPosition

错误信息如下:

2018-09-10 12:09:57.669 [pool-7-thread-1] ERROR com.alibaba.otter.canal.kafka.producer.CanalKafkaStarter - no match ack positionLogPosition[identity=LogIdentity[sourceAddress=/47.97.169.27:3317,slaveId=-1],postion=EntryPosition[included=false,journalName=mysql-bin.000003,position=7080270,serverId=20183317,gtid=,timestamp=1536552101000]]

sql: update t_order_shop_0024 set modify_time = now() ;

binlog filter config canal.instance.filter.druid.ddl = true canal.instance.filter.query.dcl = true canal.instance.filter.query.dml = true canal.instance.filter.query.ddl = true canal.instance.filter.table.error = true canal.instance.filter.rows = false canal.instance.filter.transaction.entry = true

解析的binlog信息:

Batch Id: [149136] ,count : [1] , memsize : [8064] , Time : 2018-09-10 12:30:11 Start : [mysql-bin.000003:7080270:1536552101000(2018-09-10 12:01:41)] End : [mysql-bin.000003:7080270:1536552101000(2018-09-10 12:01:41)] kafka的消息一直在增长,看日志binlog全部是上面这个mysql-bin.000003:7080270:1536552101000

原提问者GitHub用户yin007008

展开
收起
Java工程师 2023-05-08 19:16:21 90 0
1 条回答
写回答
取消 提交回答
  • 需要位点更新的使用的,不能将canal.instance.filter.transaction.entry设置为true

    原回答者GitHub用户wingerx

    2023-05-09 19:45:30
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
ACK 云原生弹性方案—云原生时代的加速器 立即下载
ACK集群类型选择最佳实践 立即下载
企业运维之云原生和Kubernetes 实战 立即下载

相关镜像