GCP PubSub订户stopAsync().awaitTerminated()挂起
GCP PubSub订户stopAsync().awaitTerminated()挂起
提问于 2018-10-21 14:15:47
我正在调用subscriber.stopAsync().awaitTerminated()，但它再也没有返回。当我暂停调试时，我看到一堆线程“grpc-default-worker- the”似乎被private native int kevent0(int var1, long var2, int var4, long var5);调用卡住了。主线程正在等待UNSAFE.park(false, 0L)调用的java.util.concurrent.locks.LockSupport.park()
在我尝试停止订阅者之前，它的行为与预期一样(初始化、startAsync().awaitRunning()调用、MessageReceived回调)
有没有人遇到过类似的问题，或者有任何想法来解决这个问题？
回答 1
Stack Overflow用户
回答已采纳
发布于 2018-10-22 01:50:30
听起来你有一些消息没有被确认或破解过。客户端保留未完成消息的计数，并挂起等待它到达0，如果您的代码路径既没有达到这一点，它永远也不会。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/52912621
复制相关文章
相似问题