Kafka 使用汇总-白红宇

Kafka 使用汇总

阅读量：4205 次

发布时间：2019-05-26

本文共 6205 字，大约阅读时间需要 20 分钟。

简介

Zookeeper搭建

bin/zkServer.sh start

启动Kafaka 拒绝链接

问题

[2020-02-19 14:58:13,666] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:13,672] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:14,778] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:14,779] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:15,879] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:15,880] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:16,981] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:16,982] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:18,083] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:18,084] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:19,185] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)[2020-02-19 14:58:19,186] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)java.net.ConnectException: 拒绝连接	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712)	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)[2020-02-19 14:58:19,672] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING	at kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply$mcV$sp(ZooKeeperClient.scala:225)	at kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply(ZooKeeperClient.scala:221)	at kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply(ZooKeeperClient.scala:221)	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)	at kafka.zookeeper.ZooKeeperClient.kafka$zookeeper$ZooKeeperClient$$waitUntilConnected(ZooKeeperClient.scala:221)	at kafka.zookeeper.ZooKeeperClient.
   
    (ZooKeeperClient.scala:95)	at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1547)	at kafka.server.KafkaServer.kafka$server$KafkaServer$$createZkClient$1(KafkaServer.scala:348)	at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:372)	at kafka.server.KafkaServer.startup(KafkaServer.scala:202)	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)	at kafka.Kafka$.main(Kafka.scala:75)	at kafka.Kafka.main(Kafka.scala)[2020-02-19 14:58:19,673] INFO shutting down (kafka.server.KafkaServer)[2020-02-19 14:58:19,676] WARN  (kafka.utils.CoreUtils$)java.lang.NullPointerException	at kafka.server.KafkaServer$$anonfun$shutdown$5.apply$mcV$sp(KafkaServer.scala:572)	at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)	at kafka.server.KafkaServer.shutdown(KafkaServer.scala:572)	at kafka.server.KafkaServer.startup(KafkaServer.scala:329)	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)	at kafka.Kafka$.main(Kafka.scala:75)	at kafka.Kafka.main(Kafka.scala)[2020-02-19 14:58:19,680] INFO shut down completed (kafka.server.KafkaServer)[2020-02-19 14:58:19,680] ERROR Exiting Kafka. (kafka.server.KafkaServerStartable)[2020-02-19 14:58:19,682] INFO shutting down (kafka.server.KafkaServer)

尝试：