Linux 安装单机kafka，细到极致

3、下载kafka，选.tgz的

4、老哥已经提前下载好了

[root@VM-4-2-centos zookeeper]# ls
apache-zookeeper-3.5.7-bin.tar.gz  kafka_2.13-3.0.1.tgz

5、查看jdk是否安装，非常重要

[root@VM-4-2-centos zookeeper]# java -version
java version "1.8.0_311"
Java(TM) SE Runtime Environment (build 1.8.0_311-b11)
Java HotSpot(TM) 64-Bit Server VM (build 25.311-b11, mixed mode)

6、解压zookeeper,然后重命名

[root@VM-4-2-centos zookeeper]# tar -zxvf apache-zookeeper-3.5.7-bin.tar.gz 
[root@VM-4-2-centos zookeeper]# mv apache-zookeeper-3.5.7-bin zookeeper

7、zookeeper有个很无语的地方，conf文件下有个配置文件需要重命名

[root@VM-4-2-centos zookeeper]# cd zookeeper/conf/
[root@VM-4-2-centos conf]# mv zoo_sample.cfg  zoo.cfg

8、修改zoo.cfg配置文件的日志路径，在zoo.cfg后面加上一句(zk需要一个端口备用，默认是8080) 为了防止8080端口被占用

[root@VM-4-2-centos conf]# pwd
/opt/zookeeper/zookeeper/conf
[root@VM-4-2-centos conf]# vi zoo.cfg

admin.serverPort=8888

9、外面创建log文件夹，然后启动

[root@VM-4-2-centos conf]# cd ../ && mkdir log
[root@VM-4-2-centos zookeeper]# ./bin/zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /opt/zookeeper/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

10、检查一下是否启动，出现QuorumPeerMain，代表zk启动成功，如果没有的话，可以去当前的logs文件夹看日志，一般的人是不会教你这些的

[root@VM-4-2-centos zookeeper]# jps
2699880 QuorumPeerMain
1740700 Bootstrap
2700101 Jps
[root@VM-4-2-centos zookeeper]# lsof -i:2181
COMMAND     PID USER   FD   TYPE    DEVICE SIZE/OFF NODE NAME
java    2699880 root   51u  IPv6 108690897      0t0  TCP *:eforward (LISTEN)

11、重点来了，先解压kafka安装包，然后重命名

[root@VM-4-2-centos zookeeper]# tar -zxvf kafka_2.13-3.0.1.tgz 
[root@VM-4-2-centos zookeeper]# mv kafka_2.13-3.0.1 kafka

12、进入配置文件目录

[root@VM-4-2-centos zookeeper]# cd kafka/config/
[root@VM-4-2-centos config]# pwd
/opt/zookeeper/kafka/config
[root@VM-4-2-centos config]# vi server.properties

13、需要修改两个地方，一个是advertised后面,添加你的公网ip地址，可以通过curl ifconfig.me查看；另外一个是日志位置 14、上去，启动kafka

[root@VM-4-2-centos config]# cd ..
[root@VM-4-2-centos kafka]# ./bin/kafka-server-start.sh -daemon ./config/server.properties &

15、查看状态，启动成功！

[root@VM-4-2-centos kafka]# jps
2699880 QuorumPeerMain
1740700 Bootstrap
2702798 Jps
2702533 Kafka
[root@VM-4-2-centos kafka]# lsof -i:9092
COMMAND     PID USER   FD   TYPE    DEVICE SIZE/OFF NODE NAME
java    2702533 root  134u  IPv6 108700509      0t0  TCP *:XmlIpcRegSvc (LISTEN)

16、kafka可以通过控制台发送消息，老哥简单演示一下 先创建一个topic test

./bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --bootstrap-server 101.34.7.236:9092

生产者:

./bin/kafka-console-producer.sh --broker-list 101.34.7.236:9092 --topic test

消费者:

./bin/kafka-console-consumer.sh --bootstrap-server 101.34.7.236:9092 --topic test