我们在 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) …Run Code Online (Sandbox Code Playgroud) apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect
我创建了一个 vpc,并创建了两个子网,一个是公共子网(附加到互联网网关),另一个是私有子网。我可以从公共子网访问私有子网。我的问题是流量如何从私有子网发送到公共子网?私有子网与主路由表相关联。而且它只有到本地的路由。