 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 |
|
|
mcy
|
2d41bb9960
|
修改mq配置针对destination级别重启
|
2018-11-09 18:19:51 +08:00 |
|
|
mcy
|
7d7c82ce91
|
修改mq配置针对destination级别重启
|
2018-11-09 18:12:04 +08:00 |
|
|
mcy
|
2a38bca34b
|
代码整理
|
2018-11-09 16:52:34 +08:00 |
|
|
mcy
|
c5bd42bbf1
|
canal server端 MQ 配置修改
MQ配置可动态加载
|
2018-11-09 16:39:52 +08:00 |
|
|
mcy
|
f7ea8df89e
|
rdb新增同步测试完成
|
2018-11-08 11:19:50 +08:00 |
|
|
mcy
|
b71e299161
|
kafka单个partition的发送未改为同步发送的bug fix
|
2018-11-07 11:37:16 +08:00 |
|
 jiacheo
|
edb5f294ef
|
fix：rollback之后继续commit，会产生 CanalServerException: ack error , clientId:1001 batchId:12 is not exist , please check 的错误。
|
2018-11-05 22:00:56 +08:00 |
|
|
rewerma
|
d3e1ddd234
|
Merge pull request #1084 from rewerma/master
fix #1083
|
2018-11-01 14:47:33 +08:00 |
|
|
mcy
|
b9c4884af1
|
fix #1083
|
2018-11-01 14:46:29 +08:00 |
|
 七锋
|
dd8243a56d
|
fixed issue #1075, support message transactor filter
|
2018-10-30 23:48:05 +08:00 |
|
|
七锋
|
be5f1546ca
|
fixed issue #1063 , rocketmq bugfix
|
2018-10-29 16:56:29 +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 |
|
|
七锋
|
071545987b
|
fixed mq config
|
2018-10-28 21:15:57 +08:00 |
|
|
七锋
|
a0b38a9cac
|
fixed MQConnector
|
2018-10-28 19:52:26 +08:00 |
|
 duhengforever
|
ebaf78f5aa
|
Resolve conflict with master branch
|
2018-10-28 16:18:13 +08:00 |
|