• 主页
• 运维
• 开发
• 公告
• 登录
• 注册

1、环境介绍

系统：centos7

Zookeeper：2.8.0

Kafka：3.7.0

 

2、安装zookeeper

安装zookeeper的步骤按照一下文档

https://www.yunweigonghui.com/column/Zookeeper/318/

 

3、安装kafka

安装非常简单，解压文件至/data

tar -zxf kafka_2.13-2.8.0.tgz -C /data

启动kafka

前提是必须启动zookeeper

nohup ./kafka-server-start.sh ../config/server.properties &

关闭kafka

./kafka-server-stop.sh

 

4、操作kafka

(1)新建主题

命令创建topic，命名为test

因为为单节点，所以备份节点为1个

创建分区，分区数目为3

依赖的zookeeper是本机的zookeeper，端口是2181

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test

 

(2)启动生产者

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

 

(3)启动消费者

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

在/lib/systemd/system中添加文件以下文件

cat >/lib/systemd/system/kafka.service<<EOF  

[Unit]

Description=Apache Kafka server (broker)

After=network.target  zookeeper.service

[Service]

Type=simple

User=root

Group=root

ExecStart=/data/kafka/bin/kafka-server-start.sh /data/kafka/config/server.properties

ExecStop=/data/kafka/bin/kafka-server-stop.sh

Restart=on-failure

[Install]

WantedBy=multi-user.target

EOF