我们在kafka服务器中遇到以下异常。请告诉我为什么会出现此问题？这个问题一直出现在生产环境中。Kafka版本是2.12-2.3.0

rEpoch=Optional[2708]), rds_exception-1=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[3628]), __consumer_offsets-34=(fetchOffset=0, logStartOffse

t=0, maxBytes=1048576, currentLeaderEpoch=Optional[3002]), rde_exception-1=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[3765]), RDE_FLOW.object_

mapper4-6=(fetchOffset=1, logStartOffset=1, maxBytes=1048576, currentLeaderEpoch=Optional[2676]), __consumer_offsets-16=(fetchOffset=1502, logStartOffset=0, maxBytes=1048576, curr

entLeaderEpoch=Optional[2996]), RDS_FLOW.JsonToRDS-1=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[3637]), KF_SET_AS_DOWNLOADED_RESC_PROD-13=(fe

tchOffset=704121, logStartOffset=653504, maxBytes=1048576, currentLeaderEpoch=Optional[2854]), RDS_FLOW.FromMongo-2=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLead

erEpoch=Optional[3596]), RDE_FLOW.getTMBLicenseScript6-3=(fetchOffset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[2711]), __consumer_offsets-5=(fetchOffset=

439993802, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[3743])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=1197409999, epoch=INITIAL), rac

kId=) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
        at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
        at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107)
        at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:197)
        at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286)
        at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133)
        at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132)
        at scala.Option.foreach(Option.scala:274)
        at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132)
        at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89)
[2020-06-11 13:02:36,970] INFO Registered kafka:type=kafka.Log4jController MBean