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
900 Commits 13 Branches 38 Tags
dac642f7448c12323639529671c5dee926a8d6d1
Commit Graph

92 Commits

Author SHA1 Message Date
mcy
f04447837c client打fat包排除其他 2018-11-29 10:21:27 +08:00
agapple
9aaf20fb5e [maven-release-plugin] prepare for next development iteration 2018-11-26 13:22:04 +08:00
agapple
8496ceaf15 [maven-release-plugin] prepare release canal-1.1.2 2018-11-26 13:21:51 +08:00
agapple
cc97f3b331 Merge pull request #1171 from rewerma/master 
adapter 分批同步
 2018-11-21 22:09:33 +08:00
mcy
56ec66f90e adapter 分批同步 2018-11-21 13:46:30 +08:00
agapple
c0bbe530f1 Merge pull request #1169 from ymwneu/supportRocketMQ 
[ISSUE#1109]Support aliyun RocketMQ
 2018-11-21 12:51:31 +08:00
maowei.ymw
4bfc476e08 Modify rocketMQ related pom 2018-11-21 10:44:58 +08:00
agapple
b6f1e0d13c fixed rocketmq ack npe 2018-11-20 17:14:29 +08:00
maowei.ymw
50630cc934 Support client connect rocketmq in aliyun 2018-11-19 14:33:59 +08:00
machey
3090557eeb client 排除jsr305不打进fat jar 2018-11-06 23:16:11 +08:00
mcy
dab6fa5aa1 Merge branch 'master' of https://github.com/rewerma/canal 2018-11-05 15:31:41 +08:00
jiacheo
9473f4e8fd Update CanalMessageDeserializer.java 
fix lazyParseEntry 'raw' wrong value.
 2018-11-02 01:48:17 +08:00
mcy
e1191b665e es配置加载 2018-10-30 15:57:00 +08:00
mcy
e4e23c9ecd 增加adapter相关参数: retry timeout batchSize 2018-10-30 14:13:51 +08:00
七锋
b9f40f326f [maven-release-plugin] prepare for next development iteration 2018-10-29 14:57:39 +08:00
七锋
774aeeea68 [maven-release-plugin] prepare release canal-1.1.1 2018-10-29 14:57:25 +08:00
mcy
b131e8cfa4 CanalConnector接口去掉stopRunning接口 2018-10-29 01:40:34 +08:00
mcy
167858cd95 解决分布式同步开关关闭同步状态下, 
重启 kafka canal-adapter后在开启同步,丢失数据的bug
 2018-10-28 22:35:32 +08:00
mcy
3b4d28eec3 测试修改 2018-10-28 21:30:54 +08:00
七锋
071545987b fixed mq config 2018-10-28 21:15:57 +08:00
七锋
a0b38a9cac fixed MQConnector 2018-10-28 19:52:26 +08:00
duhengforever
b484593869 Add flat message support to rocketmq 2018-10-28 16:09:31 +08:00
mcy
e4b6385dcc 调整kafka同步发送和消费，确保消息不丢失 2018-10-03 16:32:08 +08:00
mcy
2e92ec3e4d client模块中rocketmq-client包scope provide，外部使用单独依赖 2018-10-03 12:27:56 +08:00
七锋
eb2a83b975 fixed test 2018-09-30 11:33:48 +08:00
七锋
9344ed121f format & import 2018-09-30 10:52:41 +08:00
duhengforever
3ed8987779 Remove useless log print 2018-09-30 09:49:13 +08:00
duhengforever
fa8588f766 Modify canal-client config and polish consumer implementation 2018-09-30 09:40:05 +08:00
duhengforever
5ae16b1c7c Merge canal repo master 2018-09-27 17:09:00 +08:00
duhengforever
a37a7ff142 Add RocketMQ example and polish mq abstract class 2018-09-27 10:34:17 +08:00
duhengforever
d5aa324ce4 Add RocketMQ canal connector 2018-09-20 15:48:52 +08:00
rewerma
e9439125bd Merge branch 'master' into master 2018-09-18 10:18:22 +08:00
WithLin
1a8d6e65cf FIx 2018-09-17 11:18:00 +08:00
WithLin
9748fceda8 fix proto3 bug 2018-09-17 11:11:30 +08:00
mcy
7005c11ac2 fix序列化的一些问题, kafka生产端统一使用异步 2018-09-17 11:10:50 +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
mcy
e450c3f83f fix #912 通过maven插件将guava修改包路径打包进canal.client 2018-09-11 11:35:47 +08:00
machey
ee5775ce05 去掉kafka server端TRANSACTIONBEGIN和TRANSACTIONEND的判断 2018-09-02 20:21:07 +08:00
mcy
6b94f396ff 移除kafka client基于zk的HA机制 2018-08-24 10:52:04 +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
fc3de4b7fd 整合canal.client和canal.kafka-client 2018-08-23 17:38:17 +08:00
七锋
9bde69b6d6 [maven-release-plugin] prepare for next development iteration 2018-08-20 13:29:12 +08:00
七锋
dd8b1ce955 [maven-release-plugin] prepare release canal-1.1.0 2018-08-20 13:28:57 +08:00
七锋
8a74504fe3 preapre for 1.1.0 release 2018-08-14 13:29:03 +08:00
七锋
5582a38930 fixed issue #726, 优化SessionHandler里直接拼byte[],绕过protobuf的多次拷贝 2018-07-19 13:35:38 +08:00
七锋
10bb800f85 fixed issue #726 , 优化SessionHandler的传输处理,提前序列化Entry 2018-07-18 18:21:45 +08:00
七锋
bef6a66eaf fixed issue #296, support getWithoutAck/ack/rollback for NPE 2018-07-16 23:00:35 +08:00
rewerma
f2e3ff2dae 增加canal-kafka-client的running状态监控 2018-06-21 11:30:11 +08:00