报 ：mq get/ack not support concurrent & async ack Error sync but ACK! 然后报mq的channel死了 然后就收不到消息了 mq队列消息不被消费了 我自己用connector写的java client改用了非ack模式没问题，我的理解是mq 不能异步ack，adapter es又异步ack了，但是我用adapter没改动什么东西，就只是修改了配置而已，为什么...

在这个切换，重启的这段时间，mysql产生的数据会不会丢

Why you need it? clickhouse 作为 列存储数据库，现在应用较多，能否增加对 clickhouse 的支持，使得能够将 MySQL的数据实时同步到 clickhouse 中去。 非常感谢！ How it could be? Other related information 我在网上找到了 一位开发者对 canal 的源码修改，在源码中导入ck的驱动包、然后修改启动方法中对数据库类型...

canal组件版本1.1.6

dump address /:3306 has an error, retrying. caused by com.alibaba.otter.canal.parse.exception.CanalParseException: java.lang.NullPointerException Caused by: java.lang.NullPointerException at com.taobao.tddl.dbsync.binlog.event.GtidLogEvent.getLastCommitted(GtidLogEvent.java:80) at com.alibaba.otter....

主配置 节点信息 创建实例信息 实例配置信息 报错日志 2023-01-13 19:03:27.055 [canal-instance-scan-0] INFO c.a.otter.canal.instance.spring.CanalInstanceWithSpring - start CannalInstance for 1-mysql0 2023-01-13 19:03:27.056 [canal-instance-scan-0] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEve...

Question 架构如下所示： 主库a -> 从库 b-> canal 服务端 主库a通过binlog将数据同步到从库b，之间正常同步，然后canal服务端当做从库b的从库，canal收到消息后，会将消息发送到kafka、 问题：主库a每天都有更新，从库b也都能收到a的消息并更新数据，但是canal 却接收不到数据。但是如果通过工具直接修改从库b的数...

我认为这是一个Bug，不管是decimal还是scaled_float都是为了防止精度问题，但是canal却直接将decimal强转为了number，导致精度问题 源码：ESSyncUtil 104行 case "float": case "half_float": case "scaled_float": if (val instanceof Number) { res = ((Number) val).floatValue(); } else { res = Float.parseFloat(val...

I have searched the issues of this repository and believe that this is not a duplicate. I have checked the FAQ of this repository and believe that this is not a duplicate. environment canal-1.1.5 mysql8.0.18 Issue Description 我看原先的issue中提到 gtid模式下,会存在长期不更新zookeeper中cursor的...

我在启动adapter的时候，报错 `Positive matches: ConfigurationPropertiesRebinderAutoConfiguration matched: - @ConditionalOnBean (types: org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor; SearchStrategy: all) found bean 'org.springframework.boot.context.properties....