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)
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 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 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<>();
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 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 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 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: