kafka安装和基本使用
程序员文章站
2022-06-14 10:45:42
...
一、kafka单机安装
1.下载 kafka_2.9.2-0.8.1.1.tgz
2.将文件解压
3.进入 kafka_2.9.2-0.8.1.1/config 目录
4.修改 server.properties文件
参数 |
参考参数值 |
broker.id |
0 |
port |
9092 |
log.dirs |
kafka_2.9.2-0.8.1.1/logs |
zookeeper.connect |
zookeeper31:2181,zookeeper32:2181,zookeeper33:2181 |
5.修改hosts文件
vi /etc/hosts
192.168.178.129 zookeeper31
192.168.178.130 zookeeper32
192.168.178.131 zookeeper33
6.在kafka根目录执行
bin/kafka-server-start.sh config/server.properties &
7.创建topic 执行如下命令:
bin/kafka-topics.sh --create --zookeeper zookeeper31:2181 --replication-factor 1 --partitions 3 --topic mydemo1
8.查看所有topic
bin/kafka-topics.sh --list --zookeeper zookeeper31:2181 --topic mydemo1
9.查看topic详细信息
bin/kafka-topics.sh --describe --zookeeper zookeeperr31:2181 --topic mydemo1
10.停止kafka 进程
bin/kafka-server-stop.sh config/server.properties
二、创建单机多Broker伪分布式
ddd
d参数111
1.复制server.properties 为 server1.properties,并修改如下内容
参数 |
参考参数值 |
broker.id |
1 |
port |
9093 |
log.dirs |
/root/training/kafka_2.9.2-0.8.1.1/logs/broker1 |
zookeeper.connect |
zookeeper31:2181,zookeeper32:2181,zookeeper33:2181 |
三、多机多Broker的配置
四、Kafka发送消息和接收消息
1.发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mydemo1
2.控制台 接收消息
bin/kafka-console-consumer.sh --zookeeper zookeeper31:2181 --topic mydemo1
上一篇: kafka配置
下一篇: 免费留言本 挑战最棒的留言本的源码(四)