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,462 Commits 13 Branches 38 Tags
b48c434ffd61786aba5f8555b61e98ee5014cb55
Commit Graph

61 Commits

Author SHA1 Message Date
Chad2li
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
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
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
文哥
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
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
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
agapple
1fa9020599 format 2019-10-15 21:38:48 +08:00
shicongyang
65b5325ca6 建议增加一个属性，针对根据某一字段hash时，hash算法可以不根据database算出 #2248 (#2294) 2019-10-15 21:32:42 +08:00
agapple
d505b5ab9d fixed issue #2258 , optimizer rocketmq send perf 2019-09-30 20:19:25 +08:00
耐小心
79552e0a37 rabbitmq(amqp)MQ支持 (#2156) 2019-09-16 12:43:02 +08:00
agapple
c76e8ba0e4 fixed canal-admin 2019-08-31 15:23:58 +08:00
agapple
4e0b8a0278 fixed admin 2019-08-31 12:24:41 +08:00
agapple
bf89974f7c fixed issue #2099 , support remote config poll 2019-08-27 16:11:20 +08:00
rewerma
2e1b7a5093 通过http从canal-admin中拉配置 (#2093) 
* modify

* http拉取配置监听

* revert main pom

* 整理代码
 2019-08-26 19:01:08 +08:00
agapple
3d4dbc9a8c fixed issue #2099 , support user/passwd acl and canal admin operator 2019-08-26 18:16:33 +08:00
agapple
3a74f6124a fixed issue #1940 #2088 , add canal.register.ip support docker 2019-08-22 23:48:19 +08:00
mcy
015026ea91 modify 2019-07-11 21:31:38 +08:00
mcy
e4b37f33de modify 2019-07-11 20:44:39 +08:00
mcy
317439670c modify 2019-07-11 10:16:12 +08:00
agapple
adccc0e912 add logger info for query_log_event 2019-06-19 15:04:22 +08:00
BillowX
74489d1bba 当MQ配置为Kafka时，支持配置Kerberos认证 (#1895) 2019-06-18 15:02:14 +08:00
Heng Du
d0a83aad27 Support seamless docking with Alibaba Cloud RocketMQ commercial service (#1849) 2019-05-27 23:51:32 +08:00
rewerma
16f335c381 修复rest etl 存在SQL注入风险 (#1685) 
* kafka 模式默认开启事务异步发送

* fix adapter etl rest sql inject bug
 2019-04-15 23:58:12 +08:00
machey
d76d25df6c flatMessage模式下默认canal.mq.lingerMs=100 2019-04-04 00:14:27 +08:00
dragonlong1986
7abf50f233 key改成大写，小写不会生效 2019-03-02 10:25:19 +08:00
mcy
ad62275cd7 增加kafka自定义properties 2019-02-05 19:20:36 +08:00
machey
2f214ce3a6 采用事务批量异步投递kafka flatMessage 
fixed #1454
 2019-01-20 14:20:06 +08:00
machey
100b43a5db Merge branch 'feature/mgr' 2018-12-30 16:50:32 +08:00
machey
71b7c0b868 canal server增加数据库远程配置 2018-12-30 16:44:35 +08:00
agapple
14ba358525 fixed dymaic topic 2018-12-28 18:35:50 +08:00
gl
839d5415fc add max.request.size config 2018-11-24 22:48:54 +08:00
Alan
ad18e0335d 等号两边都有空格 
格式保持一致,看起来更像大厂出品  ^_^
 2018-11-21 16:31:46 +08:00
agapple
638952fad1 fixed binlog seek & aliyun ak/sk 2018-11-21 13:51:34 +08:00
mcy
68d8aee6c3 配置整理 2018-11-14 11:32:01 +08:00
mcy
c376f0afd2 配置中增加 canal.mq.acks canal.mq.compressionType 2018-11-14 11:14:32 +08:00
agapple
cc1574d913 fixed adapter 2018-11-11 01:15:02 +08:00
mcy
c5bd42bbf1 canal server端 MQ 配置修改 
MQ配置可动态加载
 2018-11-09 16:39:52 +08:00
七锋
f822761ab2 fixed issue #1047 , support snapshot expire 2018-10-26 23:46:41 +08:00
七锋
346d091d00 fixed issue #1032 , support raw config 2018-10-25 13:11:34 +08:00
七锋
9344ed121f format & import 2018-09-30 10:52:41 +08:00
duhengforever
d5aa324ce4 Add RocketMQ canal connector 2018-09-20 15:48:52 +08:00
machey
4fe6c36c49 Merge branch 'develop-tmp' 
# Conflicts:
#	kafka-client/pom.xml
#	kafka/pom.xml
 2018-08-23 23:59:20 +08:00
mcy
e7f07d7d3e 整合canal.server和canal.kafka 2018-08-23 17:33:15 +08:00
七锋
a1588e5f98 fixed merge code 2018-08-15 19:45:11 +08:00
七锋
11d4761bcb fixed docker build 2018-08-14 13:23:24 +08:00
agapple
72213bb80d Merge pull request #833 from lcybo/master 
store增加bufferSize，metrics server端口可配置
 2018-08-13 22:42:01 +08:00
Chuanyi Li
a3bf1d59e6 Add size label for store metrics. 2018-08-13 21:03:30 +08:00
七锋
d3f52c6d3d fixed issue #727 , support rds binlog dump 2018-08-13 10:16:28 +08:00