Commit Graph

  • c3402a97f3 etl 增加同步锁 mcy 2018-10-25 17:34:15 +08:00
  • 6ee6b3c398 同步分布式开关 mcy 2018-10-25 16:43:33 +08:00
  • 42a4abe4c7 HBase etl锁定同步等待 mcy 2018-10-25 14:24:33 +08:00
  • 0f1334c92c 加入同步开关 mcy 2018-10-25 13:52:52 +08:00
  • 346d091d00 fixed issue #1032 , support raw config 七锋 2018-10-25 13:11:34 +08:00
  • 27dba9ec1b HBase根据datasourceKey导入 mcy 2018-10-25 10:52:55 +08:00
  • 8dbf63e436 增加adapter assembly打包 mcy 2018-10-25 10:05:05 +08:00
  • 30a11c75cb HBase的etl初步完成 mcy 2018-10-24 20:47:25 +08:00
  • 49caff5759 HBase的etl初步完成 mcy 2018-10-24 19:12:16 +08:00
  • 0a7251add0 HBase的etl初步完成 mcy 2018-10-24 18:30:42 +08:00
  • b5dac60cbb fixed cliet-adapter artifactId 七锋 2018-10-24 17:00:56 +08:00
  • 9270834631 fixed rds ak/sk config for manager 七锋 2018-10-24 16:46:26 +08:00
  • 575dd59c78 fixed mysql set(8 bit) type parse 七锋 2018-10-24 16:25:28 +08:00
  • 15e79c1400 调整Hbase适配 mcy 2018-10-24 15:40:48 +08:00
  • c75c248086 fixed issue #1019 , support canal embedded with Entry 七锋 2018-10-24 13:45:58 +08:00
  • 741f6310b3 Merge pull request #13 from alibaba/master rewerma 2018-10-24 13:25:15 +08:00
  • 2202ec451a Merge pull request #1028 from ttting/master rewerma 2018-10-24 12:58:00 +08:00
  • 1830458b6b Merge pull request #1031 from rewerma/master rewerma 2018-10-24 12:56:55 +08:00
  • 1b88430f71 去掉client-launcher, 移入client-adapter中重命名为example, 调整其他相关模块结构 mcy 2018-10-24 12:55:42 +08:00
  • bbb4c4347e 修改adapter-launcher模块名为launcher mcy 2018-10-24 12:44:19 +08:00
  • 0ee46ad70e jar包依赖调整 mcy 2018-10-24 11:49:58 +08:00
  • 243e129710 jar包依赖调整 mcy 2018-10-24 11:43:36 +08:00
  • a91f204682 新增adapter-launcher springboot工程 mcy 2018-10-24 11:29:28 +08:00
  • 5bc5eec85e Fix Kafka FlatMessage Model Null Value set to "" titeng.jiang 2018-10-24 10:02:50 +08:00
  • 80d3781d81 Update README.md agapple 2018-10-23 23:27:42 +08:00
  • b1e2ab4448 Update README.md agapple 2018-10-23 23:25:05 +08:00
  • 3e49e33f9f Merge pull request #12 from alibaba/master rewerma 2018-10-23 15:38:45 +08:00
  • 986840b6bf Merge pull request #1014 from wingerx/master agapple 2018-10-19 12:57:47 +08:00
  • 61aea888f6 Merge remote-tracking branch 'upstream/master' winger 2018-10-19 10:30:16 +08:00
  • c16037122b 修复通过show master status获取到多个GTID 时,回车符导致UUID 解析失败的bug winger 2018-10-19 10:27:50 +08:00
  • a823b909ad upgrade spring version 3.2.18 七锋 2018-10-17 18:35:32 +08:00
  • 5d55c7ac00 fixed fastsql upgrade 七锋 2018-10-17 15:43:26 +08:00
  • 75f380252e Merge pull request #11 from alibaba/master rewerma 2018-10-17 00:48:03 +08:00
  • 5eb67990ca fixed es reset 七锋 2018-10-16 16:57:57 +08:00
  • 017fe87e4b fixed issue #928, support Dml.executeTime 七锋 2018-10-16 16:55:30 +08:00
  • fc050c3ce9 fixed issue #980 , support TSDB dup column 七锋 2018-10-16 16:45:25 +08:00
  • b893aafae7 fixed issue #1001 , support docker restart 七锋 2018-10-16 13:33:45 +08:00
  • 9c24b26d02 fixed gtid 七锋 2018-10-16 13:29:53 +08:00
  • 22d1fc98ee Merge pull request #1006 from WithLin/patch-2 agapple 2018-10-16 13:12:43 +08:00
  • d88f204a15 Merge pull request #1002 from wallellen/fix-release-threadpool agapple 2018-10-16 11:36:28 +08:00
  • 5d0f79932a Update README.md XiaoFu 2018-10-15 18:36:08 +08:00
  • 7c44e5933d 1. AbstractEventParser 中应该对multiStageCoprocess每次在while最后进行stop而不是reset, reset会在mysqlMultiStageCoprocessor中重新创建两个线程池, 如果在dump出错的情况下, 会无限多的创建multiStageCoprocess而且不释放 wallellen 2018-10-12 18:27:32 +08:00
  • 4d36c60738 Merge pull request #990 from shicmV5/master agapple 2018-10-09 22:15:46 +08:00
  • 53c2a02124 增加 目标数据库密码加密解密,采用druid方式进行加密解密,并设置canal.instance.enableDruid=true时,请使用druid加密数据库密码。false时,就是使用明文密码。 shichengming 2018-10-09 16:49:33 +08:00
  • 1701a4c97c Merge pull request #981 from rewerma/master agapple 2018-10-08 10:29:46 +08:00
  • e4b6385dcc 调整kafka同步发送和消费,确保消息不丢失 mcy 2018-10-03 16:32:08 +08:00
  • 2e92ec3e4d client模块中rocketmq-client包scope provide,外部使用单独依赖 mcy 2018-10-03 12:27:56 +08:00
  • d20485027f Merge pull request #10 from alibaba/master rewerma 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
  • c3327e567e Merge pull request #973 from duhengforever/develop_rocketmq agapple 2018-09-30 10:28:37 +08:00
  • 3ed8987779 Remove useless log print duhengforever 2018-09-30 09:49:13 +08:00
  • fa8588f766 Modify canal-client config and polish consumer implementation duhengforever 2018-09-30 09:40:05 +08:00
  • fa8ffb8e66 Merge pull request #9 from alibaba/master rewerma 2018-09-29 15:52:23 +08:00
  • 9da8f9cc5a Merge pull request #969 from WithLin/patch-1 agapple 2018-09-29 13:50:55 +08:00
  • af03f07cc7 Modify default config duhengforever 2018-09-27 19:39:46 +08:00
  • 5ae16b1c7c Merge canal repo master duhengforever 2018-09-27 17:09:00 +08:00
  • a37a7ff142 Add RocketMQ example and polish mq abstract class duhengforever 2018-09-27 10:34:17 +08:00
  • ff592758cf Merge pull request #970 from wingerx/master agapple 2018-09-26 13:13:27 +08:00
  • b04446d24d Merge remote-tracking branch 'upstream/master' winger 2018-09-25 18:46:39 +08:00
  • 40f8c931c7 fix bug #968: 对于workpool与BatchEventProcessor需要手动调用halt(),否则会导致其使用的工作线程(池)无法正常关闭(parserExecutor/stageExecutor.shutdownNow()无效) winger 2018-09-25 18:46:10 +08:00
  • a22517adc2 Fix link error XiaoFu 2018-09-25 17:53:54 +08:00
  • 821f3eced5 Add mq adapter duhengforever 2018-09-21 18:41:37 +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
  • fd80f953e9 Update README.md agapple 2018-09-21 15:30:35 +08:00
  • 05718a9f20 Merge pull request #958 from rewerma/master agapple 2018-09-21 15:10:01 +08:00
  • 19b7f730b6 整理代码 mcy 2018-09-20 18:06:47 +08:00
  • 4f2b4cea53 整理代码 mcy 2018-09-20 17:25:32 +08:00
  • e566160f1e 整理代码 mcy 2018-09-20 17:24:32 +08:00
  • 74890050d0 kafka生产端增加按pk hash到对应partition功能 mcy 2018-09-20 16:48:14 +08:00
  • 0cda90cdea 默认将数据发现kafka的partition 0,避免多分区的数据一致性问题 后续将支持通过id hash分发数据 mcy 2018-09-20 16:17:38 +08:00
  • 1a11153cd2 Merge pull request #8 from alibaba/master rewerma 2018-09-20 16:03:43 +08:00
  • d5aa324ce4 Add RocketMQ canal connector duhengforever 2018-09-20 15:48:52 +08:00
  • 09df602f3b support filterTransactionEntry 七锋 2018-09-20 11:30:10 +08:00
  • b026c44ea8 Merge pull request #953 from DaiZZZZZ/master agapple 2018-09-20 10:15:23 +08:00
  • 19f765df77 单词拼写修正 zhikuodai 2018-09-19 15:16:38 +08:00
  • 4e1675033a Merge pull request #7 from alibaba/master rewerma 2018-09-18 10:18:32 +08:00
  • e9439125bd Merge branch 'master' into master rewerma 2018-09-18 10:18:22 +08:00
  • a11f9e4b34 Merge pull request #949 from WithLin/master agapple 2018-09-18 10:06:44 +08:00
  • 10b0ade627 Merge pull request #947 from lcybo/master agapple 2018-09-17 19:51:12 +08:00
  • 1a8d6e65cf FIx WithLin 2018-09-17 11:17:55 +08:00
  • 9748fceda8 fix proto3 bug WithLin 2018-09-17 11:11:07 +08:00
  • 7005c11ac2 fix序列化的一些问题, kafka生产端统一使用异步 mcy 2018-09-17 11:10:50 +08:00
  • 88bf2ae64d Merge pull request #3 from alibaba/master XiaoFu 2018-09-17 10:55:55 +08:00
  • cae6df1457 Update grafana tmpl. Chuanyi Li 2018-09-15 13:28:27 +08:00
  • 6682c56b9f Canal metrics group mode support. Chuanyi Li 2018-09-15 13:21:38 +08:00
  • 5394613ba6 Merge pull request #942 from wingerx/master agapple 2018-09-14 16:53:41 +08:00
  • 6e84b98651 example 增加获取当前gtid相关信息示例 winger 2018-09-14 14:22:55 +08:00
  • af1a6a851f Merge remote-tracking branch 'upstream/master' winger 2018-09-14 14:07:02 +08:00
  • 1516cf779d 将当前的gtid,sequence no 和last committed信息增加至Entry(trx begin/end, rowdata) Header 中,客户端可从property中获取相关值 winger 2018-09-14 14:06:32 +08:00
  • db56effd91 整理代码 mcy 2018-09-14 11:45:52 +08:00
  • f3d1c8b754 Merge branch 'master' of https://github.com/rewerma/canal mcy 2018-09-14 11:24:27 +08:00
  • abf6a37f3a Merge pull request #6 from alibaba/master rewerma 2018-09-14 11:24:09 +08:00
  • e8e0032404 增加扁平Message用于卡夫卡数据投递 mcy 2018-09-14 11:22:47 +08:00
  • 52734eac7e Merge pull request #938 from WithLin/master agapple 2018-09-13 18:53:10 +08:00
  • ca61be5f5a fix upgrade proto2 to proto3 WithLin 2018-09-13 18:36:36 +08:00
  • b28e3d6f18 Merge pull request #2 from alibaba/master XiaoFu 2018-09-13 15:28:54 +08:00
  • 1ab1f119b8 Merge pull request #931 from rewerma/master agapple 2018-09-12 13:22:19 +08:00