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
602 Commits 13 Branches 38 Tags
2e92ec3e4d124609dce4a3eb6a76763bb77c6ee1
Commit Graph

602 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
mcy
2e92ec3e4d client模块中rocketmq-client包scope provide，外部使用单独依赖 2018-10-03 12:27:56 +08:00
rewerma
d20485027f Merge pull request #10 from alibaba/master 
merge
 2018-10-03 12:09:49 +08:00
七锋
eb2a83b975 fixed test 2018-09-30 11:33:48 +08:00
七锋
9344ed121f format & import 2018-09-30 10:52:41 +08:00
agapple
c3327e567e Merge pull request #973 from duhengforever/develop_rocketmq 
[ISSUE 800]提供RocketMQ原生接入canal
 2018-09-30 10:28:37 +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
rewerma
fa8ffb8e66 Merge pull request #9 from alibaba/master 
merge
 2018-09-29 15:52:23 +08:00
agapple
9da8f9cc5a Merge pull request #969 from WithLin/patch-1 
Fix link error
 2018-09-29 13:50:55 +08:00
duhengforever
af03f07cc7 Modify default config 2018-09-27 19:39:46 +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
agapple
ff592758cf Merge pull request #970 from wingerx/master 
fix bug #968
 2018-09-26 13:13:27 +08:00
winger
b04446d24d Merge remote-tracking branch 'upstream/master' 2018-09-25 18:46:39 +08:00
winger
40f8c931c7 fix bug #968: 对于workpool与BatchEventProcessor需要手动调用halt()，否则会导致其使用的工作线程(池)无法正常关闭(parserExecutor/stageExecutor.shutdownNow()无效) 2018-09-25 18:46:10 +08:00
XiaoFu
a22517adc2 Fix link error 2018-09-25 17:53:54 +08:00
duhengforever
821f3eced5 Add mq adapter 
Signed-off-by: duhengforever <duhengforever@gmail.com>
 2018-09-25 10:22:31 +08:00
七锋
00ec70d425 fixed readme 2018-09-21 15:45:52 +08:00
七锋
9d48d23787 fixed readme 2018-09-21 15:44:03 +08:00
七锋
9535e82da6 fixed readme 2018-09-21 15:40:18 +08:00
agapple
fd80f953e9 Update README.md 2018-09-21 15:30:35 +08:00
agapple
05718a9f20 Merge pull request #958 from rewerma/master 
kafka生产端增加按pk hash到对应partition功能
 2018-09-21 15:10:01 +08:00
mcy
19b7f730b6 整理代码 2018-09-20 18:06:47 +08:00
mcy
4f2b4cea53 整理代码 2018-09-20 17:25:32 +08:00
mcy
e566160f1e 整理代码 2018-09-20 17:24:32 +08:00
mcy
74890050d0 kafka生产端增加按pk hash到对应partition功能 2018-09-20 16:48:14 +08:00
mcy
0cda90cdea 默认将数据发现kafka的partition 0，避免多分区的数据一致性问题 
后续将支持通过id hash分发数据
 2018-09-20 16:17:38 +08:00
rewerma
1a11153cd2 Merge pull request #8 from alibaba/master 
merge
 2018-09-20 16:03:43 +08:00
duhengforever
d5aa324ce4 Add RocketMQ canal connector 2018-09-20 15:48:52 +08:00
七锋
09df602f3b support filterTransactionEntry 2018-09-20 11:30:10 +08:00
agapple
b026c44ea8 Merge pull request #953 from DaiZZZZZ/master 
单词拼写修正
 2018-09-20 10:15:23 +08:00
zhikuodai
19f765df77 单词拼写修正 2018-09-19 15:16:38 +08:00
rewerma
4e1675033a Merge pull request #7 from alibaba/master 
merge
 2018-09-18 10:18:32 +08:00
rewerma
e9439125bd Merge branch 'master' into master 2018-09-18 10:18:22 +08:00
agapple
a11f9e4b34 Merge pull request #949 from WithLin/master 
Fix simpleCanalConnector bug
 2018-09-18 10:06:44 +08:00
agapple
10b0ade627 Merge pull request #947 from lcybo/master 
修复group模式报错
 2018-09-17 19:51:12 +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
XiaoFu
88bf2ae64d Merge pull request #3 from alibaba/master 
merge local repo
 2018-09-17 10:55:55 +08:00
Chuanyi Li
cae6df1457 Update grafana tmpl. 2018-09-15 13:28:27 +08:00
Chuanyi Li
6682c56b9f Canal metrics group mode support. 2018-09-15 13:21:38 +08:00
agapple
5394613ba6 Merge pull request #942 from wingerx/master 
增加当前的gtid相关信息至Entry Header
 2018-09-14 16:53:41 +08:00
winger
6e84b98651 example 增加获取当前gtid相关信息示例 2018-09-14 14:22:55 +08:00
winger
af1a6a851f Merge remote-tracking branch 'upstream/master' 2018-09-14 14:07:02 +08:00
winger
1516cf779d 将当前的gtid，sequence no 和last committed信息增加至Entry(trx begin/end, rowdata) Header 中,客户端可从property中获取相关值 2018-09-14 14:06:32 +08:00
mcy
db56effd91 整理代码 2018-09-14 11:45:52 +08:00
mcy
f3d1c8b754 Merge branch 'master' of https://github.com/rewerma/canal 2018-09-14 11:24:27 +08:00
rewerma
abf6a37f3a Merge pull request #6 from alibaba/master 
merge alibaba/canal
 2018-09-14 11:24:09 +08:00
mcy
e8e0032404 增加扁平Message用于卡夫卡数据投递 2018-09-14 11:22:47 +08:00