小编use*_*331的帖子

在读取响应之前,与 2 的 Kafka 连接已断开

我们在 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

5
推荐指数
0
解决办法
4491
查看次数

AWS 公有子网和私有子网流量

我创建了一个 vpc,并创建了两个子网,一个是公共子网(附加到互联网网关),另一个是私有子网。我可以从公共子网访问私有子网。我的问题是流量如何从私有子网发送到公共子网?私有子网与主路由表相关联。而且它只有到本地的路由。

如果可能的话,您能否与我见面,了解路线表中的流量(入站和出站)? 在此输入图像描述

amazon-s3 amazon-ec2 amazon-web-services aws-lambda

2
推荐指数
1
解决办法
2030
查看次数