Alessandro (Ale) Segala
|
f4e73b0e65
|
Update dapr/kit (#3205)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
|
2023-11-02 16:20:56 -07:00 |
Naah
|
615d4911bf
|
rocketmq consumer support some config item (#2811)
Signed-off-by: Naah <nayan3480232@163.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
|
2023-05-04 10:57:03 -07:00 |
jinjianfeng-chn
|
875abcda56
|
Add rocketmq configuration items. Add orderly message. (#2198)
* Add rocketmq configuration items. Add orderly message. Change the version of rocketmq-client-go to v2.1.0.
Signed-off-by: jinjianfeng-chn <feng081212@163.com>
* modtidy
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: jinjianfeng-chn <feng081212@163.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
|
2022-11-10 11:54:40 -08:00 |
Bernd Verst
|
47a46673cd
|
PubSub: Fall back to 'consumerID' when group not present
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
|
2022-10-27 14:08:37 -07:00 |
Bruce Huang
|
a6ad8cb4bf
|
RocketMQ fix metadata properties (#1817)
* Removes the useless metadata attributes, AccessProto and ConsumerBatchSize, rename GroupName to ProducerGroup
Signed-off-by: helbing <helbingxxx@gmail.com>
* RocketMQ SendTimeout unit is seconds
Signed-off-by: helbing <helbingxxx@gmail.com>
* avoid breaking change
Signed-off-by: helbing <helbingxxx@gmail.com>
* implement ConsumerBatchSize option
Signed-off-by: helbing <helbingxxx@gmail.com>
* avoid breaking change
Signed-off-by: helbing <helbingxxx@gmail.com>
* add deprecated log
Signed-off-by: helbing <helbingxxx@gmail.com>
* backwards-compatibility sendTimeOut
Signed-off-by: helbing <helbingxxx@gmail.com>
* fix lint
Signed-off-by: helbing <helbingxxx@gmail.com>
* add logger import
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: helbing <helbingxxx@gmail.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: addjuarez <addiajuarez@gmail.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
|
2022-09-14 14:45:47 -07:00 |
|
Bernd Verst
|
1d0ad9c6d8
|
Use standardized metadata parser
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
|
2022-09-12 18:50:05 -07:00 |
Dmitry Shmulevich
|
c7adb917f3
|
update license to Apache v2.0 (#1406)
|
2022-01-04 19:53:31 -08:00 |
Zach
|
5c9365b314
|
pub/sub rocketmq:upgrade with v2 (#1383)
* pub/sub rocketmq:upgrade with client v2
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:remove cache and add start with setup
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:fix variable golint
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:change license and fix goimports
Signed-off-by: zach <zachchou016@gmail.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
|
2021-12-31 12:18:27 -08:00 |