centos7部署单机kafka

centos7部署单机kafka

   小樱     2021年6月6日 11:50     592    

1、环境介绍

系统:centos7

Zookeeper2.8.0

Kafka3.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




文章评论

0

其他文章