java - GCP PubSub 订阅者 stopAsync().awaitTermminate() 挂起

Question

我正在调用subscriber.stopAsync().awaitTermminate()，但它永远不会返回。当我暂停调试时，我看到一堆线程“grpc-default-worker-something”似乎卡在 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 回调)

有人遇到过类似的问题或有任何想法如何解决这个问题吗？

Answer 1

听起来您有尚未确认或确认的消息。客户端会记录未完成消息的计数并挂起等待其到达 0，如果您的代码路径两者都没有达到，则永远不会。