jianghang.loujh
a96db39420
add polardb-x parser test
2022-06-13 09:39:29 +08:00
温绍锦
bac1d543f1
update fastjson & druid version ( #4224 )
...
* 修复升级2.0.4导致兼容的问题
* update druid & fastjson version
2022-06-13 09:31:46 +08:00
jianghang.loujh
753fad6639
fixed issue #4216 , support polardb-x show tables
2022-06-10 13:36:39 +08:00
jianghang.loujh
bc4dceea1a
fixed issue #4216 , support polardb-x show databases
2022-06-10 11:37:52 +08:00
温绍锦
7aaee7b439
修复升级2.0.4导致兼容的问题 ( #4202 )
2022-05-30 10:29:38 +08:00
温绍锦
e19bf1ecff
Fastjson2 compatible fix ( #4189 )
...
* update fastjson2 version, 2.0.2 -> 2.0.3
* update fastjson & druid version
* bug fix for fastjson2 compatible
2022-05-25 10:22:26 +08:00
jianghang.loujh
a99dc0cbe8
fixed testcase
2022-05-24 11:18:40 +08:00
jianghang.loujh
7b8ff04d20
[maven-release-plugin] prepare for next development iteration
2022-05-24 10:26:12 +08:00
jianghang.loujh
7ee246ca5a
[maven-release-plugin] prepare release canal-1.1.6
2022-05-24 10:26:06 +08:00
jianghang.loujh
54c645f315
fixed test failed
2022-05-24 10:12:26 +08:00
jianghang.loujh
6c81ab6fdc
fixed compiler error
2022-05-24 10:08:02 +08:00
jianghang.loujh
99aefaa118
support mysql 8.0 transaction_payload_event
2022-05-23 23:23:52 +08:00
jianghang.loujh
e2248b3d35
update phoenix pom.xml
2022-05-23 19:30:19 +08:00
jianghang.loujh
eef1ee85fb
fixed issue #4014 , support java8 & java11 G1 GC
2022-05-23 18:23:31 +08:00
温绍锦
7dfec19c68
update druid & fastjson2 version ( #4183 )
...
* update fastjson2 version, 2.0.2 -> 2.0.3
* update fastjson & druid version
2022-05-23 10:03:41 +08:00
jianghang.loujh
05a52f1bd3
upgrade log4j version
2022-05-20 16:58:20 +08:00
jianghang.loujh
fb0f274ba8
fixed logger
2022-05-20 16:09:53 +08:00
jianghang.loujh
d71a208123
fixed issue #4178 , support -00:00:00.12
2022-05-20 10:37:53 +08:00
jianghang.loujh
656a1d23c2
instance.properties demo
2022-05-19 19:56:50 +08:00
jianghang.loujh
a574b91fdf
fixed #3976 , support LogEvent.MYSQL_TYPE_TYPED_ARRAY
2022-05-19 19:53:54 +08:00
jianghang.loujh
e41e903984
fixed issue #3538 , compatiable mysql8.0 filed meta
2022-05-17 17:17:32 +08:00
jianghang.loujh
4a22d72ef4
fixed issue #4018 , fixed CanalInstanceWithManager thread-safe
2022-05-16 19:46:34 +08:00
jianghang.loujh
b7eff723a3
fixed issue #4027 , CanalServerWithEmbedded.get support newList
2022-05-16 19:41:46 +08:00
jianghang.loujh
9b9cfe4037
fixed issue #4152 , TableMetaTSDB support canal.instance.filter.query.ddl=true
2022-05-16 17:25:43 +08:00
jianghang.loujh
ee51f338e0
fixed outAdapterkey autoGen
2022-05-13 15:13:14 +08:00
zhuchao941 and agapple
4315f203a2
repair issue #3401 ( #3923 )
...
* 解决OutAdapter单例导致的问题,如 1.多个es7 outAdapter的多线程问题(共享同一个es bulk request),2.多个es7 outAdapter共用一份es配置问题
* 1. 优化adapter和监听器之间的代码结构
2. 监听器只处理匹配的配置文件
3. bugfix-es adapter配置文件回调时漏写esVersion
理论上一个adapter实例对应一个config配置文件
Co-authored-by: agapple <jianghang.loujh@alibaba-inc.com >
2022-05-13 15:02:06 +08:00
jianghang.loujh
b12945d4a9
format yml
2022-05-13 14:39:57 +08:00
885f05fb6a
支持定义rocketmq client日志路径,及修复一些bug ( #3229 )
...
* 修复接入阿里云RocketMq no route info for this topic 问题
* 支持deployer同步rocketmq时定义rocketmq client日志路径
* 支持deployer同步rocketmq时定义rocketmq client日志路径
* 回退guava版本号,解决adapter的java.lang.NoSuchMethodError: com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor()异常
* 解决adapter启动报com.alibaba.druid.pool.DruidDataSource cannot be cast to com.alibaba.druid.pool.DruidDataSource异常。
* 支持rocketmq client 配置日志路径
Co-authored-by: hai.yu <hai.yu@snowballtech.com >
Co-authored-by: agapple <jianghang.loujh@alibaba-inc.com >
2022-05-13 14:39:29 +08:00
ChengTie(鐵手)
591126ee6b
update ( #3326 )
2022-05-13 14:37:17 +08:00
He Wang
af432bf10a
fix data truncated for column issue for type year ( #3866 )
2022-05-13 14:33:06 +08:00
jumao
b532e90ff4
ESAdapter Support the same instance cross -library query ( #4161 )
...
* ESAdapter Support the same instance cross -library query
* fix null point ex
2022-05-13 14:31:09 +08:00
xiaoyu.zhang
e48bc35f35
通过索引别名获取mapping,返回数据为真实索引,而不是别名,导致mappings.get(index).get(type)报空指针异常 ( #4122 )
2022-05-13 14:28:53 +08:00
He Wang
11a5f2a0fa
add druid stat filter ( #3985 )
2022-05-13 14:24:37 +08:00
He Wang and agapple
c775478a56
set backtick by DbType ( #3984 )
...
Co-authored-by: agapple <jianghang.loujh@alibaba-inc.com >
2022-05-13 14:23:40 +08:00
He Wang
bd1f91cd9c
fix sync order in RdbMirrorDbSyncService ( #3928 )
2022-05-13 14:19:40 +08:00
jianghang.loujh
67e85d201c
remove client adapter Docker
2022-05-13 12:46:12 +08:00
wanglei
6965726dfe
fix bug #2023 ( #3871 )
...
* fix bug #2023
* 配置canal-adapter,docker生成脚本
2022-05-13 12:39:43 +08:00
willmao
c0001afe8f
use hostname if register name not set ( #3968 )
2022-05-13 12:24:33 +08:00
xiayingfeng
977031a666
Improve MAVEN build Performance ( #4055 )
2022-05-13 12:23:33 +08:00
zhangshaoning
bd3224eea1
Upgrade reference log4j package version ( #4017 )
2022-05-13 12:22:45 +08:00
jianghang.loujh
33733aef25
fixed compatible and code format
2022-05-13 11:59:57 +08:00
zhangjukai
25be0259a4
Some tweaks for pulsarmq-connector ( #4060 )
...
* 1. Add the com.alibaba.otter.canal.connector.core.spi.CanalMsgConsumer file to the META-INF/canal directory under the pulsarmq-connector project
2. Introduce pulsar-client-admin for Canal to automatically create multi-partition topics
3. Add the judgment that roleToken is null
4. The disconnect method in CanalPulsarMQConsumer removes this.pulsarMQConsumer.unsubscribe();, this code will cause data loss during stop
5. When getting Pulsar messages, they are all processed as flat messages, because CanalMessageSerializerUtil.deserializer(data) will deserialize exceptions
6. Use groupId as subscriptName, without the pulsarmq.subscriptName parameter, the entire adapter will be the same subscriber name using pulsarmq.subscriptName
* 逻辑优化
* 代码优化
* 针对pulsar的调整
* 恢复代码
* 恢复代码
* 处理Producer失效的情况
2022-05-13 11:41:50 +08:00
liteng2430
8114d77a20
Add verification: the user can set a password with a length of less than 6 digits when updating the password, but the password length must be greater than or equal to 6 digits when logging in to canal admin, so the length verification function when updating the login password is added ( #4103 )
2022-05-13 11:34:36 +08:00
ZhangJian He
571e7f4e25
fix ojdbc6 wrong corrinator ( #4132 )
2022-05-13 11:33:42 +08:00
温绍锦
ead91433d7
fastjson update 1.x to 2.0.2 ( #4160 )
2022-05-13 11:32:47 +08:00
xiaoma20082008
bac016f89e
<feat>: support visibility columns ( #3976 )
2022-05-13 11:30:19 +08:00
willmao
8804647c30
avoid print password when logging ( #3969 )
2022-05-13 11:28:05 +08:00
mclubing
2623d08b8c
rdb配置不支持yaml后缀文件 ( #3964 )
...
增加rdb配置支持yaml后缀文件
2022-05-13 11:26:04 +08:00
wuare
622fed84ce
fixed logger name ( #3887 )
2022-05-13 11:24:00 +08:00
He Wang
9f5e8fd1c4
rollback guava version in adapter module ( #3880 )
2022-05-13 11:23:30 +08:00
Junwang Zhao
88d472ef1e
move protocol test to protocol test directory ( #3864 )
...
1. move the protocol test to right directory
2. fix wrong string format params count
Signed-off-by: 元组 <zhaojunwang.zjw@alibaba-inc.com >
2022-05-13 11:16:06 +08:00
Aiden.Ao
2987d08161
fix issue #3144 ( #3712 )
2022-05-13 11:09:09 +08:00
tuple
b54bea5e33
polish the code thus make it more stable ( #3855 )
...
Signed-off-by: 元组 <zhaojunwang.zjw@alibaba-inc.com >
2021-10-11 14:46:22 +08:00
jianghang.loujh
c42ba95eed
fixed pulsarmq package
2021-10-09 18:06:34 +08:00
jianghang.loujh
b48c434ffd
fixed phoenix version
2021-10-09 17:52:13 +08:00
jianghang.loujh
2c892fce9b
fixed issue #3484 , fixed bat script
2021-10-09 17:39:22 +08:00
jianghang.loujh
3bb49e19d2
fixed issue #3576 , stop exporter
2021-10-09 17:29:23 +08:00
jianghang.loujh
f26b84ffc2
fixed issue #3829 , kafka connector support k8s env
2021-10-09 16:31:59 +08:00
364102729 and agapple
0a2254eeaf
add tablestore adapter ( #3754 )
...
* add tablestore adapter
* add tablestore adapter
* fix bug add add log when etl fail
* fix bug,tinyint(1)以及rowupdatechange
Co-authored-by: agapple <jianghang115@gmail.com >
2021-10-09 16:06:13 +08:00
jianghang.loujh
40d840375f
fixed MR
2021-10-09 15:59:12 +08:00
Chad2li and agapple
5b6fd8094a
增加Apache Pulsar MQ支持 ( #3791 )
...
* done pulsarmq
* del pulsar consumer
* pulsar partition
* done pulsar consumer&connector
* update pulsar-client version to 2.8.1
Co-authored-by: agapple <jianghang115@gmail.com >
2021-10-09 15:51:45 +08:00
mikoto
4ce401d219
fix: 多destination的场景下只能生效一个 ( #3772 )
2021-10-09 15:38:26 +08:00
Jonathan Schneider and Moderne
de95a6a128
refactor: Use Java standard library instead of Guava ( #3708 )
...
Co-authored-by: Moderne <team@moderne.io >
Co-authored-by: Moderne <team@moderne.io >
2021-10-09 15:33:37 +08:00
happyrita
9e11c3c018
定时保存snapshot到DB的逻辑中,schema名称获取错误,在有配置canal.instance.filter.regex时,由于对应的table无法被匹配中,导致compareTableMetaDbAndMemory方法不被执行 ( #3693 )
...
* 避免重复订阅zk变更状态
* Update DatabaseTableMeta.java
获取schema的名称
* Update CanalController.java
2021-10-09 15:32:20 +08:00
arthasking123
d67bea8f3d
repair issue #3678,#3680 ( #3684 )
...
* repair issue #3678,#3680
* repair issue #3678,#3680
2021-10-09 15:30:32 +08:00
kkjinping
997957d6e0
新增配置 canal.mq.enableDynamicQueuePartition,获取topic对应的队列的数量为分区的数量,以支持动态队列的场景(如阿里云的rocketmq,无法人工设置队列数量,可能会动态伸缩) ( #3670 )
2021-10-09 15:26:23 +08:00
tanpenggood
ea20076a32
fix: rowChange typo ( #3593 )
2021-10-09 15:23:36 +08:00
dinosaur
2550d8eb65
Connection is already closed fix ( #3587 )
2021-10-09 14:54:05 +08:00
nick
31a0fdc807
add note ( #3550 )
2021-10-09 14:53:28 +08:00
lanicc
d79431c7e5
fix typo ( #3532 )
2021-10-09 14:53:00 +08:00
ruanjl
911711248c
修复rds高可用主从切换和oss相关问题 ( #3480 )
...
* 修复rds oos 拉取的binlog 的消费逻辑以及本地消费到直连消费的逻辑衔接
* 去除无用代码
2021-10-09 14:51:41 +08:00
spark and lihuav2017
63407dc570
canal adapter phoenix ( #3290 )
...
* canal adapter phoenix
* canal adapter phoenix
* canal adapter phoenix
* canal adapter phoenix
* canal adapter phoenix
* canal adapter phoenix
* canal adapter phoenix
Co-authored-by: lihuav2017 <lihua@able-elec.com >
2021-10-09 14:37:11 +08:00
flowell
3c20fd09ad
fix issue #3839 : 修复alter table character set类型DDL语句解析BUG ( #3840 )
2021-10-09 14:28:56 +08:00
ChenZhangg and Chen Zhang
eef3bd92ba
Improve MAVEN build Performance ( #3851 )
...
Co-authored-by: Chen Zhang <340355960@qq.com >
2021-10-09 14:26:26 +08:00
agapple
474063af3b
fixed issue #3494 , polardb-x 2.0 cdc support implicit_id/varaibles
2021-04-28 13:42:55 +08:00
agapple
5cc85ff2de
[maven-release-plugin] prepare for next development iteration
2021-04-19 15:48:20 +08:00
agapple
64862503ba
[maven-release-plugin] prepare release canal-1.1.5
2021-04-19 15:48:09 +08:00
agapple
f9e0dc7daa
fixed testcase
2021-04-19 15:15:10 +08:00
agapple
0c399509a9
upgrade druid 1.2.6
2021-04-19 12:57:21 +08:00
agapple
a09cd9adb5
fixed issue #3110 , json escapse
2021-04-19 11:28:45 +08:00
agapple
1369418c6a
fixed code format & merge
2021-04-19 10:55:43 +08:00
995586041
75174a63af
增加rabbitmq消息持久化deliveryMode配置 ( #3300 )
2021-04-19 10:29:23 +08:00
zoemak
17f4ee13e7
自动注册时可自定义node server名称,canal.properties#canal.admin.register.name,为空则使用canal.register.ip ( #3459 )
2021-04-19 10:18:01 +08:00
Fei Yang
f0417502f8
fix: unit_present typo ( #3461 )
...
https://github.com/alibaba/canal/issues/3434
2021-04-19 10:16:17 +08:00
renyansongno1
a7720b51e4
支持rocketmq的消息按照tag去发送 ( #3438 )
...
* 支持rocketmq的消息按照tag去发送
并对应修改了配置文件
* 将tag的设计转移到Rocketmq的单独配置项
2021-04-19 10:14:27 +08:00
suman-lee
21904ef1dc
基于明确的I/U/D是否过滤 ( #3452 )
...
* dmls filter
* dmls filters
* 基于明确的I/U/D是否过滤
* 基于明确的I/U/D是否过滤
2021-04-19 10:10:54 +08:00
agapple
94425223bd
fixed issue #3454 , concurrent env bugfix
2021-04-17 10:57:25 +08:00
agapple
7857df9701
add sql parser testcase
2021-04-17 10:49:17 +08:00
agapple
64ea4ff222
fixed issue #3267 , fixed rockemq send null message
2021-04-17 10:25:49 +08:00
agapple
85df89f777
fixed issue #3377 , escapse schema name
2021-04-16 23:11:41 +08:00
AlphaKitty
a0f8e182ec
修复当host中存在冒号(比如https:)抛UnknownHostException问题 ( #3223 )
...
* 修复当host中存在冒号(比如https:)抛UnknownHostException问题
* 更优雅地解析url
2021-04-16 22:11:21 +08:00
温绍锦
33721d0394
update druid version ( #3146 )
...
* replace fastsql with druid
* update druid version
2021-04-16 22:09:40 +08:00
Treeyh and hai.yu
91bddfeed6
修复接入阿里云RocketMq no route info for this topic 问题 ( #3220 )
...
Co-authored-by: hai.yu <hai.yu@snowballtech.com >
2021-04-16 22:08:28 +08:00
16075140
25feab4af8
support rabbitmq port by config ( #3236 )
2021-04-16 22:07:12 +08:00
binbin
f66baeabf1
修复最近位置被remove掉,导致重复消息的问题 ( #3276 )
2021-04-16 22:03:51 +08:00
agapple
b1dc3821ea
fixed config url auth
2021-04-16 21:52:23 +08:00
Jump-Boy
f5f79104eb
fix centos 6.10 yum bug and update jdk8.rpm download url ( #3398 )
2021-04-16 21:41:55 +08:00
ltamber
e8d138d3bd
fix: uuidset combine fix ( #3432 )
2021-04-16 21:37:55 +08:00
zoemak
32d9e58915
升级rocketmq到4.8.0,并且支持环境变量优先配置 ( #3450 )
2021-04-16 21:35:11 +08:00
许道杰
58448e559d
fix: issue #2649 client-adapter启动时抛LinkageError异常、#3073 client-adapter通过启动参数传入canal.tcp.zookeeper.hosts为空值时抛异常 ( #3074 )
2021-04-16 21:25:14 +08:00
许道杰
fede3b3d1d
fix #3126 将hbase-client依赖修改为hbase-shaded-client ( #3127 )
2021-04-16 21:24:44 +08:00
许道杰
5d8ec31bc4
fix #3119 ( #3121 )
2021-04-16 21:22:31 +08:00
WangCong
82b18ebe62
feat unsigned bug ( #3104 )
2021-04-16 21:17:43 +08:00
hupeng
66408782b0
process()方法中,在retry循环中处理成功应该break ( #3080 )
...
process()方法中,在retry循环中处理成功应该break
2021-04-16 21:14:43 +08:00
许道杰
846c8870ae
fix: issue #3076 ( #3077 )
2021-04-16 21:12:12 +08:00
ljcoder and liguowang
8cfb07f07e
数据库名称如何存在中划线"-"情况下,SQL执行异常 ( #3228 )
...
Co-authored-by: liguowang <liguowang@aerozhonghaun.com >
2020-12-31 11:33:01 +08:00
文哥
d741425895
升级guava 至 22.0 ( #3184 )
...
* fix issue:#561 增加一个外部参数控制,允许位点不存在时自动重置到当前位点
* Add MariaDB GTID support
* remove client pom bad ns
* upgrade guava version to 22.0
2020-11-20 13:47:26 +08:00
文哥
20add85ff6
统一Canal 依赖的Spring 版本,升级ibatis 至mybatis ( #3182 )
...
* fix issue:#561 增加一个外部参数控制,允许位点不存在时自动重置到当前位点
* Add MariaDB GTID support
* 1. fix maven central repository url access error.(Update to https)
2. upgrade spring version to 5.0.5.RELEASE
3. upgrade ibatis to mybatis
* fix unit test run error
2020-11-20 09:24:56 +08:00
agapple
a5c09c521e
Update README.md
2020-11-02 12:54:54 +08:00
agapple
c94276b1ac
Update README.md
2020-11-02 12:53:35 +08:00
agapple
272d575c78
Update README.md
2020-11-02 12:44:59 +08:00
温绍锦
693f8d501a
replace fastsql with druid ( #3132 )
2020-10-31 13:19:03 +08:00
温绍锦
bb1b6b9862
Update README.md
2020-10-23 14:41:31 +08:00
温绍锦
8ed82caaef
Update README.md
2020-09-29 16:18:23 +08:00
文哥
de1dd70609
1. Add MariaDB gtid support 2. fix issue:#561 增加一个外部参数控制,允许位点不存在时自动重置到当前位点 ( #3025 )
...
* fix issue:#561 增加一个外部参数控制,允许位点不存在时自动重置到当前位点
* Add MariaDB GTID support
2020-09-24 17:56:40 +08:00
zavakid
09429c241f
= inner class MessageEventFactory to be static
2020-09-23 11:37:17 +08:00
zavakid
9a332940d7
= remove unused import
2020-09-23 11:34:45 +08:00
zavakid
362974b1c2
= code cleanup: remove unnessary boxing
2020-09-18 00:54:23 +08:00
zavakid
435db30b7b
= performance improve
...
- using bulk operation instead of iteration if possible
- terminate loop after condition is met
2020-09-18 00:51:53 +08:00
zavakid
e7de8289cd
= code cleanup : modified inner class to 'static' if possible
2020-09-18 00:49:48 +08:00
zavakid
5065fea963
= fix BooleanMutex's inner Sync to static class and add test case
2020-09-18 00:44:25 +08:00
zavakid
6989eb3d2b
+ fix logging call placeholders number
2020-09-17 23:26:02 +08:00
zavakid
df24596092
= code cleanup
...
- for loop replaceable with enhanced 'for' loop
- using diamond in generic type
- collapse try catch exception
- using try-with-resource
- using List#sort instead of Collections#sort
- replaced lambda with method reference
- using native compare method to compare numbers
- using switch instead of if for in ESSyncUtil
2020-09-17 23:22:25 +08:00
zavakid
43c23ffb97
= remove unused improt
2020-09-17 22:40:06 +08:00
zavakid
e7658879bc
= cold cleanup
...
* using lambda if possible (we are already building in Java8)
* using diamond when new generic instance
* remove used improt
2020-09-17 17:46:20 +08:00
zavakid
df60eda679
= code cleanup
2020-09-16 14:18:05 +08:00
liguangyao
b81e9dfeb8
支持不同topic指定专属partitionNum ( #2479 )
2020-08-22 13:11:53 +08:00
agapple
b79af46054
merge code and fixed issue #2755 #2756 #2735 #2714 #2711 #2710 #2616 #2602 #2585 #2565 #2935 #2434 #2623 #2418 #2387
2020-08-22 13:07:24 +08:00
calvinhkf
90bf9e6de5
align h2 version to 1.4.196 ( #2663 )
2020-08-20 21:19:22 +08:00
zhaohua
182163c3bd
MemoryTableMeta ddl 处理注释2 ( #2694 )
...
* MemoryTableMeta ddl 处理注释
* MemoryTableMeta ddl 处理注释2
2020-08-20 21:19:08 +08:00
dengliming
e4726972de
refactor: delete duplicate code ( #2748 )
2020-08-20 21:18:51 +08:00
dengliming
985892cf7e
Remove deprecated sudo setting. ( #2749 )
2020-08-20 21:18:37 +08:00
chank
746d51e621
Change maven repository to HTTPS ( #2763 )
...
* change maven repository to https
* change maven repository to https
2020-08-20 21:18:25 +08:00
caoyixiong
cdd077b758
FIX NPE When ddl event ( #2801 )
2020-08-20 21:18:12 +08:00
DinoZhang
72ae7ba8d7
meta admin ( #2836 )
2020-08-20 21:18:00 +08:00
Tocker
b82c8bca83
Fix:Alibaba Coding Guidelines-Object的equals方法容易抛空指针异常,应使用常量或确定有值的对象来调用equals。 ( #2919 )
2020-08-20 21:17:44 +08:00
Tocker
576406a4ce
Fix:Alibaba Coding Guidelines-所有的包装类对象之间值的比较,全部使用equals方法比较 ( #2918 )
2020-08-20 21:17:32 +08:00
Ymangz
b5b08e92e3
Unbuntu 20.0 默认sh为dash执行时会报语法异常 ( #2939 )
2020-08-20 21:17:11 +08:00
wanshao
9f6021cf36
fix(dml): revert wrong fix
2020-03-13 17:41:53 +08:00
bucketli
0e3d719a39
refact(canal):duplicate dependence
2020-03-09 14:15:40 +08:00
agapple
afbf125231
fixed format
2020-03-05 15:26:59 +08:00
agapple
b2b2a82554
client-adapter 写入kudu ( #2396 )
...
* client-adapter 提交写入kudu适配器
* kudu etl 处理数据缓存提交问题
* Update KuduTemplate.java
* 1.写入kudu前获取元数据方式更改
2.解决etl批量导入kudu数据少量丢失问题
* 1.修改文件头注释
2.调整kudu更新事件update为upsert
2020-03-05 15:22:01 +08:00
wanshao
30a1b067a8
fix(project): no need to process tinyint(1) specially #631
2020-02-28 14:34:30 +08:00
wanshao
beaca165d0
Merge branch 'master' of github.com:alibaba/canal
2020-02-28 14:24:33 +08:00
wanshao
c21c18458b
fix(project): fix isDdl judge #2599
2020-02-28 14:21:12 +08:00
agapple
5e761e14fa
format
2020-02-28 13:15:27 +08:00
agapple
18418ebd98
merge pull/2120
2020-02-28 12:29:41 +08:00
844392610
92f04f86cb
添加目标表不区分大小写的支持,并可开关(默认为区分大小写) ( #2329 )
...
* 添加目标表不区分大小写的支持,并可开关(默认为区分大小写)
* 添加目标表不区分大小写的支持,并可开关(默认为区分大小写)-format
2020-02-28 12:22:17 +08:00
littleneko
0d5505aa2c
fix_json_type_opaque_parse_err ( #2318 )
...
对于`JSONB_TYPE_OPAQUE`类型的解析计算`q_max_bytes`时,多算了`1`字节
2020-02-28 12:15:09 +08:00
zhshy11
bd56438eca
sql语句增加引号,兼容mysql关键字 ( #2358 )
2020-02-28 11:47:38 +08:00
agapple
b9a157657f
merge /pull/2373
2020-02-28 11:46:28 +08:00
agapple
523e8b85e6
format
2020-02-28 11:40:14 +08:00
agapple
ab74b2c82c
fixed mq spi package
2020-02-28 11:32:30 +08:00
rewerma
265a8e8594
模块化mq connector ( #2562 )
...
* add connector module, add kafka producer connector module for server
* add rocketMQ producer connector module for server
* add rabbitMQ producer connector module for server
* optimize code, add annotation
* add canal message consumer connector for canal-adapter module
2020-02-28 11:00:08 +08:00
jianqingdu
4fc7e5f7d9
fix bug: wrong quit command implementation ( #2554 )
2020-02-28 10:52:35 +08:00
Li Qiang
9cc8caa834
feature(canal):support start with timestamp position(empty journal_file,set position=0),#2594 ( #2595 )
2020-02-28 10:50:38 +08:00
Li Qiang
a71375dad5
fix(canal):fix endless local binlog mode with exception. ( #2597 )
2020-02-28 10:48:54 +08:00
Rg
70d8a379f2
add Rust canal client support ( #2518 )
2020-01-15 20:12:28 +08:00
rewerma
b6333f018f
Revert "修复kafka消费回滚的bug ( #2521 )" ( #2526 )
...
This reverts commit 31acfc0101 .
2020-01-02 17:04:57 +08:00
rewerma
31acfc0101
修复kafka消费回滚的bug ( #2521 )
2020-01-02 16:15:47 +08:00
rewerma
6d9ea57186
修复子线程阻塞造成不能中止的问题 ( #2508 )
2019-12-26 19:29:48 +08:00
Li Qiang
c4c0255073
Update README.md
2019-11-04 10:20:00 +08:00
agapple
1fa9020599
format
2019-10-15 21:38:48 +08:00
agapple
dd7554374f
format
2019-10-15 21:35:57 +08:00
shicongyang
65b5325ca6
建议增加一个属性,针对根据某一字段hash时,hash算法可以不根据database算出 #2248 ( #2294 )
2019-10-15 21:32:42 +08:00
agapple
b64a3e301a
fixed issue #2286 , ArithmeticException zero
2019-10-10 15:37:17 +08:00
agapple
31562919bb
rename canal-admin project to admin
2019-10-09 14:50:08 +08:00