Skip to main content

Linux安装 Kafka

通常kafka都是安装在Linux系统下的,下面我们就来说明一下如何在Linux下安装kafka。准备一台linux机器,我自己创建了一个kafka用户,各位可以根据自己的需求,创建期望的linux用户。

第一步:下载安装包

[kafka@localhost ~]$ wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.13-3.0.0.tgz --no-check-certificate

你可以直接使用上面的命令下载安装包,也可以到官网下载安装包。我自己安装时是在 /home/kafka目录下安装的,你可以根据自己的需要选择一个合适的目录。然后就是解压

[kafka@localhost ~]$ tar -zxvf kafka_2.13-3.0.0.tgz 

第二步:运行 zookeeper.

[kafka@localhost ~]$ cd kafka_2.13-3.0.0
[kafka@localhost kafka_2.13-3.0.0]$ ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

先通过 cd kafka_2.13-3.0.0 进入kafka所在目录,然后执行 ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 命令启动zookeeper。为了方便调试,一开始可以先不加 -daemon 这个后台运行的参数。不加 -daemon就可以在命令行直接看到启动日志。 加了 -daemon 就表示直接后台运行。

第三步:运行 kafka-server

[kafka@localhost kafka_2.13-3.0.0]$ ./bin/kafka-server-start.sh -daemon config/server.properties 

到此为止,kafka就正常运行起来了,可以使用kafka客户端测试一下。

测试验证

我们先看看端口是否正常监听了,通过netstat -ntulp 命令

[kafka@localhost kafka_2.13-3.0.0]$ netstat -ntulp
Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name
tcp6 0 0 :::9092 :::* LISTEN 18815/java
tcp6 0 0 :::2181 :::* LISTEN 17837/java

如上面的结果,如果你看到 9092端口(kafka默认端口)和2181端口(zookeeper默认端口)都是正常监听状态,就说明kafka已经正常运行了。如果你看不到 可以把上面第二步 和第三步的 -daemon 参数去掉,看看是否有报错。可能会有一些文件目录权限的错误。

接下来我们创建一个topic.

[kafka@localhost kafka_2.13-3.0.0]$ ./bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --topic test-topic --partitions 1 --replication-factor 1

控制台打印出

Created topic test-topic.

这就说明 topic 创建成功了。

当然这个安装只是单机的安装,如果需要集群部署,还需要修改一些配置。这个就不在这篇文章里讨论了。