[DISCUSS] proposal: APISIX support RocketMQ service plugin

Hi, community, My name is Yeliang Wang, and I am Apache APISIX Committer. At present, Apache APISIX supports Kafka in real-time log processing（ https://apisix.apache.org/docs/apisix/plugins/kafka-logger/ ）。 but, many enterprises I met, whether in transaction scenarios or log scenarios, are using Ap

[GitHub] [rocketmq] XiaoyiPeng opened a new issue #3533: It is better to specify the initialCapacity when initializing a HashMap as a local variable that will not escape.

XiaoyiPeng opened a new issue #3533: URL: https://github.com/apache/rocketmq/issues/3533 **BUG REPORT** 1. Please describe the issue you observed: When initializing a HashMap as a local variable that will not escape, it is better to specify the `initialCapacity`.

[GitHub] [rocketmq] XiaoyiPeng opened a new pull request #3534: [ISSUE #3533] optimize: It is better to specify the initialCapacity when initializing a HashMap as a local variable that will not escape

XiaoyiPeng opened a new pull request #3534: URL: https://github.com/apache/rocketmq/pull/3534 **Make sure set the target branch to `develop`** ## What is the purpose of the change for issue #3533 ## Brief changelog Specify the initialCapacity when initializing a

[GitHub] [rocketmq] zhangqiangGit-2018 opened a new pull request #3535: 消息队列

zhangqiangGit-2018 opened a new pull request #3535: URL: https://github.com/apache/rocketmq/pull/3535 **Make sure set the target branch to `develop`** ## What is the purpose of the change X ## Brief changelog XX ## Verifying this change

[GitHub] [rocketmq] coveralls commented on pull request #3534: [ISSUE #3533] optimize: It is better to specify the initialCapacity when initializing a HashMap as a local variable that will not add ele

coveralls commented on pull request #3534: URL: https://github.com/apache/rocketmq/pull/3534#issuecomment-977734029 [](https://coveralls.io/builds/44509047) Coverage decreased (-0.08%) to 55.014% when pulling **070f17

Re: [DISCUSS] proposal: APISIX support RocketMQ service plugin

expect! Bisakh Mondal 于2021年11月24日周三 下午5:54写道： > Nice proposal! I am willing to help developing the plugin on the first week > of December. > > Add-ons: As we are supporting Kafka and Rocket MQ, we should also extend > the support to Rabbit MQ, another highly used message queuing solution at > s

Re: [DISCUSS] proposal: APISIX support RocketMQ service plugin

Hi: > just like https://github.com/doujiang24/lua-resty-kafka I suggest to communicate with the rocketmq community and listen to their suggestions. If the rocketmq protocol is more complicated, we can use languages such as Java/Golang to implement a simple version first. On Wed, Nov 24, 2021 a

[GitHub] [rocketmq] ifplusor commented on pull request #3535: 消息队列

ifplusor commented on pull request #3535: URL: https://github.com/apache/rocketmq/pull/3535#issuecomment-977974892 @zhangqiangGit-2018 Could you discribe this PR？ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [DISCUSS] proposal: APISIX support RocketMQ service plugin

Nice proposal! I am willing to help developing the plugin on the first week of December. Add-ons: As we are supporting Kafka and Rocket MQ, we should also extend the support to Rabbit MQ, another highly used message queuing solution at some point in the future. There is also an open issue [1] rega

Re: [DISCUSS] proposal: APISIX support RocketMQ service plugin

Sounds great! Wish the surrounding ecology of Apache APISIX could become more and more abundant. On Wed, Nov 24, 2021 at 4:07 PM yeliang wang wrote: > Hi, community, > My name is Yeliang Wang, and I am Apache APISIX Committer. > At present, Apache APISIX supports Kafka in real-time log processin

[GitHub] [rocketmq-externals] bobosmile1170556238 opened a new issue #852: When a primary node [broker-b] of a broker goes down, the broker [broker-b] not exist will be reported when querying the mess

bobosmile1170556238 opened a new issue #852: URL: https://github.com/apache/rocketmq-externals/issues/852 I think this is a a rocketmq-console bug. When a primary node [sync-async-broker-b] of a broker goes down, the broker [sync-async-broker-b] not exist will be reported when querying t

Re: [DISCUSS] proposal: APISIX support RocketMQ service plugin

Hi， In fact, there is already a rocketmq client project in lua , https://guthub.com/yuz10/lua-resty-rocketmq ,I am glad to improve the project if any requirements not meet. ---Original--- From: "YuanSheng Wang"https://github.com/doujiang24/lua-resty-kafka I suggest to communicate with the roc

[GitHub] [rocketmq] iamqq23ue commented on pull request #3382: FIX ISSUE#2706 the problem of returning SEND_OK after flush failed,The original pull request was #2707.

iamqq23ue commented on pull request #3382: URL: https://github.com/apache/rocketmq/pull/3382#issuecomment-978919359 2、你的意思是把broker设置为只读，影响太大了。但我的意思是，按目前的修改，发生IO故障以后，接下来每次发送都会返回失败。这比把Broker设置为只读更糟糕的结果，影响更大。我提出的把Broker设置只读，client接下来会把请求发到其它健康的broker去，对用户几乎没有影响，是一个影响更小的方案。 By the way。

[GitHub] [rocketmq] duhenglucky closed issue #3527: Fix some request header setting errors and naming issues

duhenglucky closed issue #3527: URL: https://github.com/apache/rocketmq/issues/3527 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr..