代码之家 › 专栏 › 技术社区 › Thanos

Pubsub消息在到达我们的内部微服务之前就被丢弃了

reactor-netty google-cloud-pubsub netty grpc

0

Thanos · 技术社区 · 2 年前

我们正在使用谷歌云发布-订阅拉取机制,从过去几天开始,我们在服务日志中看到了以下错误-

io.grpc.StatusRuntimeException: RESOURCE_EXHAUSTED: Abrupt GOAWAY closed sent stream. HTTP/2 error code: ENHANCE_YOUR_CALM (Bandwidth exhausted), debug data: too_many_rst_streams
    at io.grpc.Status.asRuntimeException(Status.java:535)
    ... 14 common frames omitted
Wrapped by: com.google.api.gax.rpc.ResourceExhaustedException: io.grpc.StatusRuntimeException: RESOURCE_EXHAUSTED: Abrupt GOAWAY closed sent stream. HTTP/2 error code: ENHANCE_YOUR_CALM (Bandwidth exhausted), debug data: too_many_rst_streams
    at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:55)
    at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
    at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
    at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
    at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:67)
    at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
    at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
    at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
    at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1038)
    at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:808)
    at io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:563)
    at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533)
    at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
    at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
    at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
    at com.google.api.gax.grpc.ChannelPool$ReleasingClientCall$1.onClose(ChannelPool.java:535)
    at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:562)
...

使用以下谷歌云版本-

<spring-cloud-gcp.version>3.6.3</spring-cloud-gcp.version>
<spring-cloud.version>2021.0.0</spring-cloud.version>
spring boot version - 2.6.8
netty version - 4.1.82.Final
grpc version - 1.45.1
Java version - 11

我试图更新netty和grpc版本,但无济于事,在到达服务之前,消息仍然会被丢弃,并出现与上述相同的错误(描述部分)。

0 回复 | 直到 2 年前