kafka安装使用和遇到的坑

时间 2019-12-14

标签 kafka 安装使用遇到栏目 Kafka 繁體版

原文原文链接

下载安装

参考：http://www.javashuo.com/article/p-zrsmulrt-es.htmljava

https://kafka.apache.org/quickstartlinux

关闭服务

关闭zookeeper bin/zookeeper-server-stop.shapache

关闭kafka bin/kafka-server-stop.shsegmentfault

遇到的坑

问题1

[2018-04-08 11:20:32,999] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)

上面问题说明没法链接到zookeeper服务中，缘由是没有启动zk，或者启动zk后又关闭了socket

解决方法

一、单独在一个linux终端运行bin/zookeeper-server-start.sh config/zookeeper.properties 启动zk，再开一个linux终端启动kakfa服务，而后再开一个linux终端建立topicui

二、使用守护进程启动zk和kafka.net

bin/zookeeper-server-start.sh -daemon config/zookeeper.propertiescode

bin/kafka-server-start.sh -daemon config/server.propertiesserver