JanYork opened a new issue, #8819: URL: https://github.com/apache/rocketmq/issues/8819
### Before Creating the Bug Report - [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions) of this repository and believe that this is not a duplicate. - [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Runtime platform environment From the official docker image. ### RocketMQ version From the official docker image 5.3.0. ### JDK Version From the official docker image. ### Describe the Bug ``` InternalErrorException: [request-id=undefined, response-code=50001] null. NullPointerException. org.apache.rocketmq.proxy.grpc.v2.consumer.ReceiveMessageActivity.receiveMessage(ReceiveMessageActivity.java:63) at Function.check (/Users/muyouzhi/Code/nest-mq/node_modules/.pnpm/rocketmq-client-nodejs@1.0.0/node_modules/rocketmq-client-nodejs/src/exception/StatusChecker.ts:81:15) at SimpleConsumer.receiveMessage (/Users/muyouzhi/Code/nest-mq/node_modules/.pnpm/rocketmq-client-nodejs@1.0.0/node_modules/rocketmq-client-nodejs/src/consumer/Consumer.ts:78:19) at processTicksAndRejections (node:internal/process/task_queues:95:5) at SimpleConsumer.receive (/Users/muyouzhi/Code/nest-mq/node_modules/.pnpm/rocketmq-client-nodejs@1.0.0/node_modules/rocketmq-client-nodejs/src/consumer/SimpleConsumer.ts:122:12) at consumer (/Users/muyouzhi/Code/nest-mq/src/main.ts:40:22) { code: 50001 } ``` ### Steps to Reproduce ```js async function production(message: string) { const receipt = await producer.send({ topic: 'kitchen', messageGroup: '1', body: Buffer.from( JSON.stringify({ message, now: Date(), }), ), }); console.log(receipt); } async function consumer() { const simpleConsumer = new SimpleConsumer({ consumerGroup: '1', endpoints: '127.0.0.1:8081', subscriptions: new Map().set('kitchen', '*'), }); await simpleConsumer.startup(); while (true) { const messages = await simpleConsumer.receive(10); if (!messages.length) { continue; } for (const message of messages) { console.log('message=%o', message); console.log('body=%o', message.body.toString()); await simpleConsumer.ack(message); } } } ``` ``` function main() { production('hello world') consumer() } ``` ``` main() ``` This is almost a very basic operation. I did nothing but run the consumer according to the documentation and keep getting messages. It was normal at the beginning, but after running for 2-3 minutes, this error occurred. I don’t know why this error occurred. Can anyone reply to me if this is a bug? The maintainers are too busy and I have not been able to solve this problem. ### What Did You Expect to See? Normal operation. ### What Did You See Instead? It was working normally at the beginning, but after 2 to 3 minutes, my consumer could not get the message and it would just return an error to me. ### Additional Context _No response_ -- 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-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
