欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

kafka安装教程 -- 单节点-单Broker集群:只在一个节点上部署一个Broker

程序员文章站 2024-01-08 13:02:10
...

①安装jdk:  yum install java-1.8.0-openjdk.x86_64

②.去官网下载kafka_2.12-0.11.0.0.tgz

③.上传文件并解压压缩文件到/opt目录下

[aaa@qq.com /]# tar -xvzf kafka_2.12-0.11.0.0.tgz -C /opt/

④进入kafka的文件夹下(cd /opt/kafka_2.12-0.11.0.0) 启动ZooKeeper

bin/zookeeper-server-start.sh config/zookeeper.properties 

端口2181是ZooKeeper的默认端口,可以通过编辑文件config/zookeeper.properties 中的clientPort来修改监听端口。

⑤ 启动Kafka Broker

bin/kafka-server-start.sh config/server.properties 

⑥ 创建一个Topic 名称为HelloWorld

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 \
> --partitions 1 --topic HelloWorld

⑦校验Topic是否创建成功

bin/kafka-topics.sh --list --zookeeper localhost:2181 

 ⑧ 启动一个Producer并发送消息

 

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

       >hello world !

       >How are you! 

 ⑨ 启动一个Consumer并接受消息

 

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

接下来你就可以看到从producer哪里发过来的消息

如果报错内存不足的话就去bin/kafka-server-start.sh文件里把参数修改掉

kafka安装教程 -- 单节点-单Broker集群:只在一个节点上部署一个Broker