jianghang.loujh
|
7b8ff04d20
|
[maven-release-plugin] prepare for next development iteration
|
2022-05-24 10:26:12 +08:00 |
|
jianghang.loujh
|
7ee246ca5a
|
[maven-release-plugin] prepare release canal-1.1.6
|
2022-05-24 10:26:06 +08:00 |
|
温绍锦
|
ead91433d7
|
fastjson update 1.x to 2.0.2 (#4160)
|
2022-05-13 11:32:47 +08:00 |
|
jianghang.loujh
|
40d840375f
|
fixed MR
|
2021-10-09 15:59:12 +08:00 |
|
Chad2li
|
5b6fd8094a
|
增加Apache Pulsar MQ支持 (#3791)
* done pulsarmq
* del pulsar consumer
* pulsar partition
* done pulsar consumer&connector
* update pulsar-client version to 2.8.1
Co-authored-by: agapple <jianghang115@gmail.com>
|
2021-10-09 15:51:45 +08:00 |
|
Jonathan Schneider
|
de95a6a128
|
refactor: Use Java standard library instead of Guava (#3708)
Co-authored-by: Moderne <team@moderne.io>
Co-authored-by: Moderne <team@moderne.io>
|
2021-10-09 15:33:37 +08:00 |
|
kkjinping
|
997957d6e0
|
新增配置 canal.mq.enableDynamicQueuePartition，获取topic对应的队列的数量为分区的数量，以支持动态队列的场景（如阿里云的rocketmq，无法人工设置队列数量，可能会动态伸缩） (#3670)
|
2021-10-09 15:26:23 +08:00 |
|
nick
|
31a0fdc807
|
add note (#3550)
|
2021-10-09 14:53:28 +08:00 |
|
agapple
|
5cc85ff2de
|
[maven-release-plugin] prepare for next development iteration
|
2021-04-19 15:48:20 +08:00 |
|
agapple
|
64862503ba
|
[maven-release-plugin] prepare release canal-1.1.5
|
2021-04-19 15:48:09 +08:00 |
|
agapple
|
1369418c6a
|
fixed code format & merge
|
2021-04-19 10:55:43 +08:00 |
|
renyansongno1
|
a7720b51e4
|
支持rocketmq的消息按照tag去发送 (#3438)
* 支持rocketmq的消息按照tag去发送
并对应修改了配置文件
* 将tag的设计转移到Rocketmq的单独配置项
|
2021-04-19 10:14:27 +08:00 |
|
agapple
|
64ea4ff222
|
fixed issue #3267 , fixed rockemq send null message
|
2021-04-17 10:25:49 +08:00 |
|
zoemak
|
32d9e58915
|
升级rocketmq到4.8.0，并且支持环境变量优先配置 (#3450)
|
2021-04-16 21:35:11 +08:00 |
|
liguangyao
|
b81e9dfeb8
|
支持不同topic指定专属partitionNum (#2479)
|
2020-08-22 13:11:53 +08:00 |
|
agapple
|
b79af46054
|
merge code and fixed issue #2755 #2756 #2735 #2714 #2711 #2710 #2616 #2602 #2585 #2565 #2935 #2434 #2623 #2418 #2387
|
2020-08-22 13:07:24 +08:00 |
|
agapple
|
523e8b85e6
|
format
|
2020-02-28 11:40:14 +08:00 |
|
rewerma
|
265a8e8594
|
模块化mq connector (#2562)
* add connector module, add kafka producer connector module for server
* add rocketMQ producer connector module for server
* add rabbitMQ producer connector module for server
* optimize code, add annotation
* add canal message consumer connector for canal-adapter module
|
2020-02-28 11:00:08 +08:00 |
|