1、下载kafka
wget https://mirrors.bfsu.edu.cn/apache/kafka/2.8.0/kafka_2.12-2.8.0.tgz
2、解压 tar -zxvf kafka_2.12-2.8.0.tgz
3、重命名mv kafka_2.12-2.8.0 kafka
4、配置环境变量 vim /etc/profile
添加两行加的代码
export KAFKA_HOME=/home/install/kafka
export PATH=$PATH:$KAFKA_HOME/bin
5、保存环境变量 source /etc/profile
6、在kafka安装目录下新增log日志目录 mkdir kafka-logs
7、修改kafka配置文件 server.propertiescd /home/install/kafka/config
vim server.properties
修改以下属性
设置kafka日志目录
log.dirs=/home/install/kafka/kafka-logs
设置 kafka的hostname、listeners和advertised
host.name=127.0.0.1
listeners=PLAINTEXT://192.168.225.128:9092
advertised.listeners=PLAINTEXT://192.168.225.128:9092
advertised.host.name=192.168.225.128
设置zookeeper的连接地址
zookeeper.connect=192.168.225.128:2181
到这里就安装成功了kafka
Kafka相关命令
cd /home/install/kafka/bin
这里增加-daemon 是为了持久化
./kafka-server-start.sh -daemon ../config/server.properties 启动kafka
ps -ef | grep kafka 查看kafka进程 启动成功有进程
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1 创建topic
sudo /home/install/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.225.128:9092 --topic test1 --from-beginning 查看这个topic的消息
./bin/kafka-topics.sh --list --zookeeper localhost:2181 查看所有的topic
sudo /home/install/kafka/bin/kafka-consumer-groups.sh --describe --bootstrap-server 192.168.225.128:9092 --group logdowngroup1 查看这个组所有topic消费了多少，总共多少
注意点
1、查看开启zookeeper
2、查看zookeeper的端口号防火墙是否开启
firewall-cmd --zone=public --add-port=80/tcp --permanent 开启某个端口
firewall-cmd --reload 重启防火墙
