Kafka transport 消费压力大时大量报 EOF 的错误

[qiulin]

错误信息：

{"level":"error","ts":"2024-09-20T10:24:28.846+0800","msg":"[kafka] FetchMessage error: EOF","service_id":"adventure-service-c446ff847-w2sgg","service_name":"adventure-service","version":"release-v5.9.4-202409181503","stacktrace":"github.com/go-kratos/kratos/contrib/log/zap/v2.(*Logger).Log\n\t/go/pkg/mod/github.com/go-kratos/kratos/contrib/log/zap/v2@v2.0.0-20240401040316-f715eb0bd808/zap.go:61\ngithub.com/go-kratos/kratos/v2/log.Errorf\n\t/go/pkg/mod/github.com/go-kratos/kratos/v2@v2.7.3/log/global.go:103\ngithub.com/tx7do/kratos-transport/broker/kafka.(*kafkaBroker).Subscribe.func1\n\t/go/pkg/mod/github.com/tx7do/kratos-transport/broker/kafka@v1.2.6/kafka.go:612"}

且消费速度变得很慢：

后面加了机器恢复。

Kafka 服务端版本 阿里云 Kafka 0.10.2