rocketmq5.0 proxy 消息体交大,并发发送消息 会提示io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 2.9999S #7041
Unanswered
happysdong
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
由于我的生产者与rocketmq是在同一个内网环境当中,但是消费者一般都是在公网环境下进行消费,所以使用了proxy模式。
环境是一个broker两个slave,一个proxy。由于使用proxy发送消息不支持批量发送,所以在应用层将几百甚至上千条消息放到了一个消息体中进行发送,在消费端进行解析处理,一切都是因为我的并发量有点高。
但是单线程生产时延时还是比较高,所以想使用多线程进行写消息,但是会提示如下错误:
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 2.9999S;
应该如何处理呢?
Beta Was this translation helpful? Give feedback.
All reactions