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文件里把参数修改掉
上一篇: easyexcel 列宽、行高、样式
下一篇: HTTP请求分片传输