报 :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没改动什么东西,就只是修改了配置而已,为什么...
Why you need it?
clickhouse 作为 列存储数据库,现在应用较多,能否增加对 clickhouse 的支持,使得能够将 MySQL的数据实时同步到 clickhouse 中去。
非常感谢!
How it could be?
Other related information
我在网上找到了 一位开发者对 canal 的源码修改,在源码中导入ck的驱动包、然后修改启动方法中对数据库类型...
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....
我认为这是一个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的...