GCP PubSub Абонент stopAsync (). AwaitTeridity () зависает

Question

Я звоню subscriber.stopAsync().awaitTerminated(), и он никогда не возвращается.Когда я приостанавливаю отладку, я вижу, что куча потоков "grpc-default-worker-что-то", похоже, застряла при вызове private native int kevent0(int var1, long var2, int var4, long var5);.Основной поток ожидает на java.util.concurrent.locks.LockSupport.park() на UNSAFE.park(false, 0L) вызове

Прежде чем я попытаюсь остановить абонента, он ведет себя как ожидалось (инициализация, startAsync().awaitRunning() вызов, MessageReceived обратные вызовы)

ИмеетУ кого-нибудь была похожая проблема или есть идеи, как ее решить?

Answer 1

Похоже, у вас есть сообщения, которые не были взломаны или взломаны.Клиент ведет подсчет ожидающих сообщений и зависает, ожидая, пока он достигнет 0, чего никогда не будет, если у вас есть кодовые пути, которые не делают ни того, ни другого.