七锋
|
dd8b1ce955
|
[maven-release-plugin] prepare release canal-1.1.0
|
2018-08-20 13:28:57 +08:00 |
|
agapple
|
15526aab8c
|
Merge pull request #840 from wingerx/master
升级Kafka 版本至 2.11_1.1.1
|
2018-08-14 16:37:09 +08:00 |
|
winger
|
679fd464f4
|
升级Kafka 版本至 2.11_1.1.1
|
2018-08-14 16:09:44 +08:00 |
|
七锋
|
8a74504fe3
|
preapre for 1.1.0 release
|
2018-08-14 13:29:03 +08:00 |
|
七锋
|
26edbeaa28
|
fixed kafka performance
|
2018-08-02 13:58:41 +08:00 |
|
rewerma
|
f2e3ff2dae
|
增加canal-kafka-client的running状态监控
|
2018-06-21 11:30:11 +08:00 |
|
mcy
|
f867b183ab
|
降低kafka依赖的版本为0.9.0.1
申明server的running为volatile
|
2018-06-18 12:15:28 +08:00 |
|
七锋
|
a4255a6377
|
fixed format
|
2018-06-14 19:25:34 +08:00 |
|
rewerma
|
e23a19cd85
|
整理代码
|
2018-06-13 18:29:15 +08:00 |
|
rewerma
|
d014167226
|
kafka consumer 默认session timeout 修改
|
2018-06-13 17:57:49 +08:00 |
|
rewerma
|
cc5eb1075b
|
kafka consumer example 修改
|
2018-06-13 15:51:28 +08:00 |
|
rewerma
|
19f4c5ae1b
|
kafka consumer 测试类修改
|
2018-06-13 15:40:49 +08:00 |
|
rewerma
|
4e41ebf746
|
kafka consumer close方式
|
2018-06-13 15:38:24 +08:00 |
|
rewerma
|
31cbdb1824
|
kafka consumer close方式
|
2018-06-13 15:36:21 +08:00 |
|
rewerma
|
1b6efdf463
|
修改kafka consumer关闭方式
|
2018-06-13 15:25:43 +08:00 |
|
rewerma
|
cb6c7ef3e8
|
完善注释
|
2018-06-13 14:24:32 +08:00 |
|
rewerma
|
9964bb75b1
|
kafka 客户端 example 完善
|
2018-06-13 14:01:30 +08:00 |
|
rewerma
|
ec072a45d8
|
kafka 客户端 example
|
2018-06-13 13:49:15 +08:00 |
|
rewerma
|
b96e4dd23a
|
kafka 客户端测试类
|
2018-06-13 11:13:35 +08:00 |
|
rewerma
|
d991e6be60
|
kafka 客户端消费代码整理
|
2018-06-13 10:34:28 +08:00 |
|
rewerma
|
e7846085fc
|
kafka 客户端消费完成基本测试
|
2018-06-12 19:25:03 +08:00 |
|