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

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伪分布式

kafka安装和基本使用

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安装和基本使用

 

四、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