[RESULT][VOTE][RIP - 63] Queue Selection Strategy Optimization

2023-04-11 Thread Ji Juntao
Hello RocketMQ Community, This is the vote result for RIP-63 Queue Selection Strategy Optimization, and it has been passed with [3] binding +1s, [0] non-binding +1s and no 0 or -1. *Binding votes +1s:* jinrongtong(jinrongt...@apache.org) Xinyu(yu...@apache.org) fuyou(fu...@apache.org)

[GitHub] [rocketmq-externals] ChengJie1053 opened a new pull request, #905: adapt Spark 3.x

2023-04-11 Thread via GitHub
ChengJie1053 opened a new pull request, #905: URL: https://github.com/apache/rocketmq-externals/pull/905 adapt Spark 3.x Related issues: #904 Default support Spark3.3.1 Can be modified as required pom.xml 3.3.1 -- This is an automated message from the Apache

[GitHub] [rocketmq] jiakme added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right

2023-04-11 Thread GitBox
GitHub user jiakme added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right `private void initRocketMQPushConsumer() throws MQClientException { List pullConsumers = new ArrayList<>();

[GitHub] [rocketmq] jiakme edited a comment on the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right

2023-04-11 Thread GitBox
GitHub user jiakme edited a comment on the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right ```java private void initRocketMQPushConsumer() throws MQClientException { List pullConsumers = new ArrayList<>();

Re: [RESULT][VOTE][RIP - 63] Queue Selection Strategy Optimization

2023-04-11 Thread Ji Juntao
Here is the RIP-63's PR link: https://github.com/apache/rocketmq/pull/6568 And Also I did some tests, the link is: https://docs.google.com/document/d/1uTB_5bp6YmoghGUpFabwYsMertP7IBlNCDx9r787sOU/edit?usp=sharing I am still polishing the codes. Looking forward to your code review. >

[GitHub] [rocketmq] jiakme edited a comment on the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right

2023-04-11 Thread GitBox
GitHub user jiakme edited a comment on the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right generate DefaultLitePullConsumer instance ```java private void initRocketMQPushConsumer() throws MQClientException { List

[GitHub] [rocketmq] jiakme added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right

2023-04-11 Thread GitBox
GitHub user jiakme added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right rocketmq-dashboard:

[GitHub] [rocketmq] RongtongJin added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right

2023-04-11 Thread GitBox
GitHub user RongtongJin added a comment to the discussion: single instance with multi DefaultLitePullConsumer(use same topic and different tag) don't poll message right lite pull consumer和push consumer,需要保证订阅关系的一致 GitHub link: