We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
看了下源码,消费者是 pull 模型。 拉取消息都做了 await,Consume 就改下异步嘛? 能不能安排上?
var pr = await Pull(mq, offset, BatchSize, SuspendTimeout); if (pr != null) { switch (pr.Status) { case PullStatus.Found: if (pr.Messages != null && pr.Messages.Length > 0) { // 触发消费 **var rs = Consume(mq, pr);** 这边能改成异步么? await ConsumeAsync // 更新偏移 if (rs) { st.Offset = pr.NextBeginOffset; // 提交消费进度 await UpdateOffset(mq, st.Offset); } }
The text was updated successfully, but these errors were encountered:
564ae4f
Sorry, something went wrong.
感谢大佬
No branches or pull requests
看了下源码,消费者是 pull 模型。 拉取消息都做了 await,Consume 就改下异步嘛? 能不能安排上?
The text was updated successfully, but these errors were encountered: