Kafka:安装

1、安装jdk

# jdk安装
yum install java-1.8.0-openjdk.x86_64 -y
# java工具安装，如jps
yum install java-1.8.0-openjdk-devel.x86_64 -y

2、zookeeper集群搭建

这里使用是kafka自带的zookeeper
三个节点 192.100.3.25、26、 27

2.1、修改配置文件：

vim config/zookeeper.properties

# 集群必须
initLimit=10
# 集群必须
syncLimit=5
# 数据目录
dataDir=/tmp/zookeeper/data
dataLogDir=/tmp/zookeeper/log
clientPort=2181
maxClientCnxns=0
admin.enableServer=false
server.1=192.100.3.25:2888:3888
server.2=192.100.3.26:2888:3888
server.3=192.100.3.27:2888:3888

2.2、创建数据目录和日志目录

mkdir -p /tmp/zookeeper/{data,log}
需要在每个服务器/tmp/zookeeper/data下创建一个myid文件，内容为zookeeper的id,这里为1、2、3。

2.3、启动

在三个节点中分别启动

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties        
# 客户端测试连接
bin/zookeeper-shell.sh localhost
get /zookeeper/config  
server.1=192.100.3.25:2888:3888:participant
server.2=192.100.3.26:2888:3888:participant
server.3=192.100.3.27:2888:3888:participant
version=0

-daemon 表示后台启动

3、kafka集群搭建

3.1、修改配置文件

vim config/server.properties

# 全局唯一编号，不能重复
broker.id=0
delete.topic.enable=true
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=192.100.3.25:2181,192.100.3.26:2181,192.100.3.27:2181

3.2、启动

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