203 Commits

Author	SHA1	Message	Date
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
Xin Wang	8cb85753bb	open the switch to get codecov test coverage (#1671) ... * add codecov for test coverage	2019-04-09 19:11:48 +08:00
agapple	69df50fe17	fixed issue #1672 , CanalKafkaProducer send	2019-04-08 19:57:00 +08:00
agapple	fadfe1d6ca	[maven-release-plugin] prepare for next development iteration	2019-04-04 10:25:44 +08:00
agapple	a7b12c7098	[maven-release-plugin] prepare release canal-1.1.3	2019-04-04 10:25:29 +08:00
agapple	82ed9db8ae	fixed rocketmq partition out of range	2019-04-03 11:26:31 +08:00
agapple	a7f9a779ad	fixed issue #1640 , support schema partition	2019-03-28 17:01:36 +08:00
wangsaner	9826948ebb	修改canal.mq.partitionHash散列规则， ... 当指明pk级做分区（schema.table:pk1^pk2）时，由table.hashCode()^column.getValue().hashCode()改为database.hashCode()^column.getValue().hashCode()，从而支持同库下不同表hash至相同分区	2019-03-28 16:01:02 +08:00
agapple	97640b717b	fixed compiler	2019-03-28 10:23:33 +08:00
wangsaner	739963acd0	fixed issue #1636 ... 非flat模式，当MQ主题为多分区时，数据拆分只取了for循环里面的最后一份数据， 导致消费端只能消费到一个分区的数据	2019-03-27 21:57:04 +08:00
agapple	0ec4699149	fixed format & support Mysql Auth Switch Protocol	2019-03-27 11:54:40 +08:00
agapple	661d119265	fixed issue #1625, mq dymaic topic match	2019-03-25 17:54:35 +08:00
agapple	531b535228	fixed bug	2019-03-21 20:26:00 +08:00
agapple	024ffc2aa2	fixed mq partition num priority	2019-03-21 19:39:21 +08:00
agapple	a81d2710ff	fixed MQ partition	2019-03-21 19:27:39 +08:00
mcy	971c9a88c2	modify	2019-03-12 17:07:33 +08:00
mcy	ad39559f8c	fix #1585	2019-03-12 16:56:59 +08:00
TomlongTK	fd4c8db92b	fix issue 1532 ... 因为binlog日志同表名大小写的原因导致kafka的日志恢复并resize，报错之后引起集群崩溃 现在修改为投递消息的topic不区分表名大小写	2019-02-26 14:23:29 +08:00
agapple	072420c32b	fixed	2019-02-25 15:18:04 +08:00
agapple	62338a945e	Merge pull request #1496 from rewerma/master ... 远程配置代码整理	2019-02-18 21:08:02 +08:00
i404	44beaf1916	修复当 canal.mq.flatMessage = true 时，MQMessageUtils::messagePartition 数据分区错误的 bug	2019-02-14 18:26:01 +08:00
mcy	ad62275cd7	增加kafka自定义properties	2019-02-05 19:20:36 +08:00
mcy	197ca67c8b	测试调整	2019-01-21 09:56:35 +08:00
machey	851637611f	modify	2019-01-20 15:02:06 +08:00
machey	4ebf17f57b	代码调整	2019-01-20 14:30:20 +08:00
machey	2f214ce3a6	采用事务批量异步投递kafka flatMessage ... fixed #1454	2019-01-20 14:20:06 +08:00
mcy	ca41be8412	fixed #1420	2019-01-15 11:38:00 +08:00
mcy	18b304f99d	specified mq dynamic topic	2019-01-14 14:25:47 +08:00
mcy	b00d347eb0	rdb adapter 增加 truncate dml适配 fixed #1408 ... fixed #1403	2019-01-11 13:40:37 +08:00
agapple	de501c85a1	fixed issue #1374 , support queryLogEvent partition	2019-01-07 13:39:04 +08:00
mcy	7c79714528	增加远程db config配置	2018-12-29 20:21:03 +08:00
mcy	150a13824b	修改 kafka 异步发送 flat message	2018-12-27 17:52:33 +08:00
mcy	d9e259dde4	增加支持按库名、表名动态发送topic支持	2018-12-27 15:40:04 +08:00
agapple	35e0e882c1	fixed hash mode	2018-12-11 20:41:21 +08:00
agapple	0197482618	fixed partitionHash format	2018-12-11 20:17:08 +08:00
agapple	277a273ebc	fixed pull #1266 , optimizer code	2018-12-11 13:40:32 +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
mcy	339ecdd817	fixed #1229	2018-11-29 17:38:13 +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	df4c66b9e2	Merge pull request #1193 from woshijay7788/feature_kafka_config ... add max.request.size config	2018-11-25 11:55:51 +08:00
guixincui	90dab6831b	修改接口引用	2018-11-24 23:40:18 +08:00
gl	839d5415fc	add max.request.size config	2018-11-24 22:48:54 +08:00
agapple	cc97f3b331	Merge pull request #1171 from rewerma/master ... adapter 分批同步	2018-11-21 22:09:33 +08:00
agapple	638952fad1	fixed binlog seek & aliyun ak/sk	2018-11-21 13:51:34 +08:00
mcy	56ec66f90e	adapter 分批同步	2018-11-21 13:46:30 +08:00
maowei.ymw	50630cc934	Support client connect rocketmq in aliyun	2018-11-19 14:33:59 +08:00
Renkai	8af1301062	Kafka增加参数acks和compressionType	2018-11-13 18:29:25 +08:00