[AdminClient clientId=adminclient-1] Connection with XXX disconnected

来源:4-6 查看Topic列表及Internal杂谈

ArvinV51

2022-07-21

运行获取topic列表方法时,(本地尝试连接kafka服务是没问题的)报出异常,如下:
13:08:31.782 [main] INFO org.apache.kafka.clients.admin.AdminClientConfig - AdminClientConfig values:
bootstrap.servers = [master1:9092, master2:9092, slave11:9092, slave12:9092, slave13:9092]
client.dns.lookup = default
client.id =
connections.max.idle.ms = 300000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 120000
retries = 5
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = https
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS

13:08:31.851 [main] DEBUG org.apache.kafka.clients.admin.internals.AdminMetadataManager - [AdminClient clientId=adminclient-1] Setting bootstrap cluster metadata Cluster(id = null, nodes = [slave11:9092 (id: -3 rack: null), master1:9092 (id: -1 rack: null), slave13:9092 (id: -5 rack: null), master2:9092 (id: -2 rack: null), slave12:9092 (id: -4 rack: null)], partitions = [], controller = null).
13:08:32.409 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed:
13:08:32.413 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created:
13:08:32.413 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name successful-authentication:
13:08:32.413 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name successful-reauthentication:
13:08:32.414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name successful-authentication-no-reauth:
13:08:32.414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name failed-authentication:
13:08:32.414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name failed-reauthentication:
13:08:32.415 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name reauthentication-latency:
13:08:32.416 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received:
13:08:32.416 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent:
13:08:32.417 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received:
13:08:32.418 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time:
13:08:32.419 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time:
13:08:32.492 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.4.0
13:08:32.492 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 77a89fcf8d7fa018
13:08:32.492 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1658380112488
13:08:32.494 [main] DEBUG org.apache.kafka.clients.admin.KafkaAdminClient - [AdminClient clientId=adminclient-1] Kafka admin client initialized
13:08:32.497 [main] DEBUG org.apache.kafka.clients.admin.KafkaAdminClient - [AdminClient clientId=adminclient-1] Queueing Call(callName=listTopics, deadlineMs=1658380232497) with a timeout 120000 ms from now.
13:08:32.501 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.clients.NetworkClient - [AdminClient clientId=adminclient-1] Initiating connection to node slave12:9092 (id: -4 rack: null) using address slave12/10.62.0.142
13:08:32.513 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node–4.bytes-sent
13:08:32.514 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node–4.bytes-received
13:08:32.515 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node–4.latency
13:08:32.518 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.common.network.Selector - [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -4
13:08:32.759 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.clients.NetworkClient - [AdminClient clientId=adminclient-1] Completed connection to node -4. Fetching API versions.
13:08:32.759 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.clients.NetworkClient - [AdminClient clientId=adminclient-1] Initiating API versions fetch from node -4.
13:08:32.857 [kafka-admin-client-thread | adminclient-1] DEBUG org.apache.kafka.common.network.Selector - [AdminClient clientId=adminclient-1] Connection with slave12/10.62.0.142 disconnected
java.io.EOFException: null
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:96)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:424)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:385)
at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:651)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:572)
at org.apache.kafka.common.network.Selector.poll(Selector.java:483)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540)
at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1196)
at java.lang.Thread.run(Thread.java:748)

写回答

1回答

Allen

2022-07-28

看错误就是没链接上,但是原因可能有很多, 比如防火墙没关闭,比如ip配置问题之类的

0
0

Kafka多维度系统精讲,从入门到实战开发

系统讲解Kafka,实战结合,让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程