消息队列之Kafka的安装与配置 – 汪明鑫的个人博客

Kafka集群的安装和配置步骤：

1，访问官网 Apache Kafka

2，下载

选择合适版本下载，注意不同的Kafka版本对jdk版本是有要求的

3，把下载的kafka安装包上传至服务器（这里我使用的winscp）

4，tar -zxvf xxxxx 解压即可

5，先查看下kafka的目录结构

之后启动kafka还会生成logs目录

6，修改config目录下的server.properties

第一个地方要修改的：

broker是kafka的一个实例 broker.id是唯一的

如果有三台服务器分别安装了kafka （要保证路径一致）

则第1台服务器kafka配成broker.id=0

第2台服务器kafka配成broker.id=1

第3台服务器kafka配成broker.id=2

第二个地方要修改的：

ip为服务器ip

第三个地方要修改的：

7,kafka的启动依赖zookeeper集群，因此先要启动zookeeper集群

8，启动Kafka

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

9，这时候查看zookeeper集群会多了一些节点

10，创建topic

sh kafka-topics.sh –create –zookeeper 192.168.88.101:2181 –replication-factor 1 –partitions 1 –topic wmx

replication-factor表示副本数

partitions表示分区数

11，使用一下kafka的生产消费

sh kafka-console-producer.sh –broker-list 192.168.88.101:9092 –topic wmx

sh kafka-console-consumer.sh –bootstrap-server 192.168.88.101:9092 –topic wmx –from-beginning

producer输入消息，consumer就可以接收到