You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/12/10 18:26:19 UTC
[GitHub] [rocketmq] yuz10 opened a new issue, #5684: serializeTypeCurrentRPC=ROCKETMQ not support pop consuming
yuz10 opened a new issue, #5684:
URL: https://github.com/apache/rocketmq/issues/5684
**BUG REPORT**
1. Please describe the issue you observed:
- What did you do (The steps to reproduce)?
1. first, open pop with ` mqadmin setConsumeMode -n localhost:9876 -c DefaultCluster -t topic -g group -m POP`
2. start rocketmq pop consumer with -Drocketmq.serialize.type=ROCKETMQ
```java
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group");
consumer.setNamesrvAddr("localhost:9876");
consumer.setClientRebalance(false);
consumer.subscribe("topic", "*");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
consumer.setClientRebalance(false);
consumer.start();
System.out.printf("Consumer Started.%n");
```
- What is expected to see?
no error
- What did you see instead?
error like "REQUEST_CODE_NOT_SUPPORTED, request type 3442 not supported"
2. Please tell us about your environment:
3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
in rocketmq serialize type, the request code is a short, the requestCode "POP_MESSAGE=200050" is larger than short max 65535.
--
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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] serializeTypeCurrentRPC=ROCKETMQ not support pop consuming [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5684:
URL: https://github.com/apache/rocketmq/issues/5684#issuecomment-1853057938
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] serializeTypeCurrentRPC=ROCKETMQ not support pop consuming [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5684:
URL: https://github.com/apache/rocketmq/issues/5684#issuecomment-1858992365
This issue was closed because it has been inactive for 3 days since being marked as stale.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] serializeTypeCurrentRPC=ROCKETMQ not support pop consuming [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #5684: serializeTypeCurrentRPC=ROCKETMQ not support pop consuming
URL: https://github.com/apache/rocketmq/issues/5684
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org