chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity
1,696 Commits 13 Branches 38 Tags
25501db3acaefa2cc8ed3378b2895027d801c990
Commit Graph

45 Commits

Author SHA1 Message Date
shicongyang
62c4333790 canal中的flatMessage中添加一个参数，记录gtid #4509 (#4521) 2022-12-23 16:04:46 +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
Jonathan Schneider
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
Fei Yang
f0417502f8 fix: unit_present typo (#3461) 
https://github.com/alibaba/canal/issues/3434
 2021-04-19 10:16:17 +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
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
agapple
bf89974f7c fixed issue #2099 , support remote config poll 2019-08-27 16:11:20 +08:00
agapple
3d4dbc9a8c fixed issue #2099 , support user/passwd acl and canal admin operator 2019-08-26 18:16:33 +08:00
agapple
4957083493 fixed issue #1897 , memory event store ack null 2019-06-25 17:32:46 +08:00
mcy
833cc55e26 FlatMessage没有默认构造方法json反序列化的问题 
Dml类增加isDdl属性
 2018-12-17 09:47:09 +08:00
agapple
277a273ebc fixed pull #1266 , optimizer code 2018-12-11 13:40:32 +08:00
machey
aeecf87490 去掉对before的判断，分区发送的表pk不能修改 2018-12-11 00:09:12 +08:00
machey
eac3f5ce5f 修改convert时设置pk 2018-12-10 23:54:07 +08:00
mcy
706ee88914 pattern表达式调整 
pk缓存
 2018-12-10 21:28:09 +08:00
mcy
99a1123e01 整理代码 2018-12-10 09:52:48 +08:00
machey
547cbf82c8 对原生message发送mq的分区支持 2018-12-10 01:03:18 +08:00
machey
03ee9c7ecf 根据主键Hash增加正则表达式支持，pk通配符指定自动获取支持 2018-12-10 00:09:49 +08:00
machey
f1710f1c7f fixed #1201 2018-11-27 22:39:49 +08:00
mcy
915849b83a 预留sync(MappingConfig config, List<Dml> dmlList)方法 
pk hash以old pk值为准若存在
 2018-11-14 20:26:38 +08:00
七锋
071545987b fixed mq config 2018-10-28 21:15:57 +08:00
七锋
9270834631 fixed rds ak/sk config for manager 2018-10-24 16:46:26 +08:00
七锋
c75c248086 fixed issue #1019 , support canal embedded with Entry 2018-10-24 13:45:58 +08:00
titeng.jiang
5bc5eec85e Fix Kafka FlatMessage Model Null Value set to "" 2018-10-24 10:02:50 +08:00
七锋
017fe87e4b fixed issue #928, support Dml.executeTime 2018-10-16 16:55:30 +08:00
七锋
9344ed121f format & import 2018-09-30 10:52:41 +08:00
duhengforever
5ae16b1c7c Merge canal repo master 2018-09-27 17:09:00 +08:00
mcy
74890050d0 kafka生产端增加按pk hash到对应partition功能 2018-09-20 16:48:14 +08:00
七锋
09df602f3b support filterTransactionEntry 2018-09-20 11:30:10 +08:00
mcy
f3d1c8b754 Merge branch 'master' of https://github.com/rewerma/canal 2018-09-14 11:24:27 +08:00
mcy
e8e0032404 增加扁平Message用于卡夫卡数据投递 2018-09-14 11:22:47 +08:00
WithLin
ca61be5f5a fix upgrade proto2 to proto3 2018-09-13 18:37:26 +08:00
WithLin
a497962153 Fix upgrade protobuf version 2018-09-07 14:27:19 +08:00
Chuanyi Li
ec00792475 Enhance heartbeat, rowscount. 2018-08-09 23:54:53 +08:00
七锋
10bb800f85 fixed issue #726 , 优化SessionHandler的传输处理,提前序列化Entry 2018-07-18 18:21:45 +08:00
七锋
a4255a6377 fixed format 2018-06-14 19:25:34 +08:00
七锋
b734a32ae6 fixed issue #626, support xa rollback/commit event 2018-06-06 11:39:59 +08:00
hiwjd
21f3f8c973 支持通过GTID同步binlog 2018-05-04 16:47:03 +08:00
agapple
4f00f5ea8d fixed tsdb test 2017-10-14 00:12:43 +08:00
agapple
ff97dcbbc9 format & import 2017-01-19 13:07:53 +08:00
agapple
c86fba6092 Merge pull request #199 from MarkLinHz/master 
upgrade protobuf version
 2016-09-19 14:03:20 +08:00
yinxiu
9742fdc9d9 upgrade protobuf version 2016-09-19 12:24:06 +08:00
agapple
ae05a3f39f fixed issue #172, 精确识别主备切换,尝试基于时间戳重新定位位点,确保不丢数据 2016-06-28 22:58:55 +08:00
agapple
7ebb3fd1ab fixed code template and format 2015-04-28 21:11:41 +08:00
wener
596b060649 cleanup code, extract CanalService 2015-04-27 14:57:01 +08:00
agapple
a0defe575b init 2014-09-23 15:11:35 +08:00