centos7部署单机kafka

centos7部署单机kafka

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

1、环境介绍

系统:centos7

Zookeeper2.8.0

Kafka3.7.0

 

2、安装zookeeper

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

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

 

3、安装kafka

安装非常简单,解压文件至/usr/local/src

tar -zxf kafka_2.13-2.8.0.tgz -C /usr/local/src

修改配置参数,这里只更改一个参数,让其他服务器能够访问到本机的kafka

advertised.listeners=PLAINTEXT://192.168.153.4:9092

这个参数默认是注释的,如果不修改此参数,外界是无法访问本机kafka

启动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


文章评论

0

其他文章