rocketmq
Here are 268 public repositories matching this topic...
see: PushConsumerWithNamespace
it always return RECONSUME_LATER in the listener.
defaultMQPushConsumer.registerMessageListener((MessageListenerConcurrently)(msgs, context) -> {
msgs.stream().forEach((msg) -> {
System.out
-
Updated
Dec 15, 2021 - Java
-
Updated
Dec 25, 2021 - Java
-
Updated
Dec 9, 2021 - Java
-
Updated
Oct 12, 2021 - Java
The issue tracker is ONLY used for bug report and feature request.
Any question or RocketMQ proposal please use our mailing lists.
BUG REPORT
- Please describe the issue you observed:
- What did you do (The steps to reproduce)?
org.apache.rocketmq.connect.hudi.connector.HudiSinkConnector
defaultKeyValue.put(HudiConnec
-
Updated
May 17, 2019
-
Updated
Oct 29, 2021 - Java
-
Updated
Oct 5, 2021 - Java
-
Updated
Dec 29, 2021 - Java
-
Updated
Dec 24, 2021 - Java
In rockemq-client-go, many log use fmt to print. Now, we have rlog, maybe we should replace fmt to rlog?
-
Updated
Dec 28, 2021 - Java
-
Updated
Dec 29, 2021 - Shell
-
Updated
Apr 26, 2021 - Java
-
Updated
Aug 12, 2021
-
Updated
Feb 9, 2019 - Java
-
Updated
Dec 26, 2021 - Python
What would you like to be added:
A Fault injection filter should provide configurable error injection capabilities, such as delay, error local reply. it is best to have more detailed routing-based configuration capabilities
Why is this needed:
Because this is the ability that is required in the testing phas
Improve this page
Add a description, image, and links to the rocketmq topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the rocketmq topic, visit your repo's landing page and select "manage topics."
Which Component
Sentinel
Describe what problem you have encountered
在hystrix和resilience4j中,我们可以配置default,对所有的feign client生效,例如熔断规则,隔离策略。在sentinel中我找不到类似的配置,似乎需要单个url去配置,这非常麻烦,请问怎么做。
In hystrix and resilience4j, we can configure "default", which will take effect for all feign clients, such as circuit breaker rules and isolation strategies. I can't find a similar configuration in sen