Re: [VOTE] RIP-21 RocketMQ Logical Queue

+1 发自我的iPhone -- Original -- From: heng du https://github.com/ayanamist) > - Shepherds: duhengfore...@apache.org > - Mailing List discussion: dev@rocketmq.apache.org > - Pull Request: #PR_NUMBER > - Released: https://github.com/apache/rocketmq/wiki/RIP-18-Metada

[GitHub] [rocketmq-externals] RongtongJin commented on pull request #717: add logstash-output-rocketmq java plugin

RongtongJin commented on pull request #717: URL: https://github.com/apache/rocketmq-externals/pull/717#issuecomment-851238968 Hi, @vongosling，this is a topic of cooperation with universities, so different students will submit logstash related PR for the rocketmq community. We can help rev

Re: [VOTE] RIP-21 RocketMQ Logical Queue

+1 "heng du" 写道： > Hi RocketMQ Community, > > This is the vote for the kickoff of RIP-21 RocketMQ logic queue. > > In order to better meet the needs of stream computing and scaling, the > concept of logical queues is proposed in this RIP, which enables RocketMQ > to hav

[GitHub] [rocketmq-exporter] xiaozongyang commented on issue #27: how support aliyun rocketmq exporter?

xiaozongyang commented on issue #27: URL: https://github.com/apache/rocketmq-exporter/issues/27#issuecomment-851223501 @3mu @francisoliverlee When I enable ACL and set accessKey and secretKey, the NPE error disappeared. And as shown in logs, brokers are listed successfully, but fetchi

[GitHub] [rocketmq] dragon-zhang commented on issue #2937: Stage Ordered and disordered comsumption support?

dragon-zhang commented on issue #2937: URL: https://github.com/apache/rocketmq/issues/2937#issuecomment-851145973 Got some troubles here, I want to read/save `current stage` in `OffsetStore`, but there is too much code to change, so I want to create a new class to solve this problem. Is th

[GitHub] [rocketmq] codecov-commenter commented on pull request #2959: [ISSUE#2949]delete the method of correctDeliverTimestamp in DeliverDelayedMessageTimerTask

codecov-commenter commented on pull request #2959: URL: https://github.com/apache/rocketmq/pull/2959#issuecomment-851128030 # [Codecov](https://codecov.io/gh/apache/rocketmq/pull/2959?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th

[GitHub] [rocketmq] coveralls commented on pull request #2959: [ISSUE#2949]delete the method of correctDeliverTimestamp in DeliverDelayedMessageTimerTask

coveralls commented on pull request #2959: URL: https://github.com/apache/rocketmq/pull/2959#issuecomment-851124554 [](https://coveralls.io/builds/40156845) Coverage decreased (-0.04%) to 51.779% when pulling **b6a740

[GitHub] [rocketmq] sunxi92 opened a new pull request #2959: [ISSUE#2949]delete the method of correctDeliverTimestamp in DeliverDelayedMessageTimerTask

sunxi92 opened a new pull request #2959: URL: https://github.com/apache/rocketmq/pull/2959 It's a redundant operation to correct deliverTimestamp when sending scheduled message, so I delete the method of correctDeliverTimestamp, and the value of countdown is the time difference between th

[GitHub] [rocketmq-externals] vongosling closed pull request #717: add logstash-output-rocketmq java plugin

vongosling closed pull request #717: URL: https://github.com/apache/rocketmq-externals/pull/717 -- 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. For queries about this ser

[GitHub] [rocketmq-externals] vongosling commented on pull request #717: add logstash-output-rocketmq java plugin

vongosling commented on pull request #717: URL: https://github.com/apache/rocketmq-externals/pull/717#issuecomment-851113417 see https://github.com/apache/rocketmq-externals/pull/722 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [rocketmq-externals] vongosling closed pull request #719: add a logstash-output-rocketmq plugin by java

vongosling closed pull request #719: URL: https://github.com/apache/rocketmq-externals/pull/719 -- 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. For queries about this ser

[GitHub] [rocketmq-externals] vongosling commented on pull request #719: add a logstash-output-rocketmq plugin by java

vongosling commented on pull request #719: URL: https://github.com/apache/rocketmq-externals/pull/719#issuecomment-85111 see https://github.com/apache/rocketmq-externals/pull/722 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [rocketmq-externals] vongosling closed issue #720: rocketmq console fail to update nameserver address

vongosling closed issue #720: URL: https://github.com/apache/rocketmq-externals/issues/720 -- 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. For queries about this service,

[GitHub] [rocketmq-externals] vongosling merged pull request #721: [ISSUE #720] fix rocketmq console fail to update nameserver address

vongosling merged pull request #721: URL: https://github.com/apache/rocketmq-externals/pull/721 -- 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. For queries about this ser

[#713] Add an logstash-output-rocketmq plugin #722

https://github.com/apache/rocketmq-externals/pull/722 Add an logstash-output-rocketmq plugin,which enables logstash to output events to rocketmq.

[GitHub] [rocketmq-externals] hehejiejie opened a new pull request #722: [#713] Add an logstash-output-rocketmq plugin

hehejiejie opened a new pull request #722: URL: https://github.com/apache/rocketmq-externals/pull/722 ## What is the purpose of the change Add an logstash-output-rocketmq plugin,which enables logstash to output events to rocketmq. ## Brief changelog XX ## Verifyi

[GitHub] [rocketmq] IntroDrop commented on issue #2957: how about using concurrenthashmap?

IntroDrop commented on issue #2957: URL: https://github.com/apache/rocketmq/issues/2957#issuecomment-850998896 Can you give me an example？thanks -- 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 t