Routine load每隔一段时间后就暂停不消费了,想问下有什么解决办法?

Viewed 80

ErrorReason{
code=errCode = 4,
msg='failed to get latest partition offset. {}errCode = 2,
detailMessage = Failed to get latest offsets of kafka topic: wmgs_inlist.
error: Waited 5 seconds (plus 101063 nanoseconds delay) for io.grpc.stub.ClientCalls$GrpcFuture@67b2c918[
status=PENDING,
info=[GrpcFuture{clientCall=ClientCallImpl{method=MethodDescriptor{fullMethodName=doris.PBackendService/get_info,
type=UNARY,
idempotent=false,
safe=false,
sampledToLocalTracing=true,
requestMarshaller=io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller@7b127a62,
responseMarshaller=io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller@1a7e3277,
schemaDescriptor=org.apache.doris.proto.PBackendServiceGrpc$PBackendServiceMethodDescriptorSupplier@4356544d}}}]]'}

1 Answers

这个情况和kafka client consumer析构卡住现象比较像,您看看在出问题的这个时间点中be.INFO 中有没有什么异常的日志,比如和某个BE节点通讯有问题什么的。