1.Download:Apache Download Mirrors
或者通过命令:
>wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz
2.解压
>tar -xzvf kafka_2.12-3.0.0.tgz -C /usr/local/software/Java/kafka/
-C:解压至指定目录
3.重命名
>mv kafka_2.12-3.0.0 kafka1
4.拷贝另外两份
>cp -r kafka1 kafka2
>cp -r kafka1 kafka3
5.修改kafka1配置文件:
>cd /usr/local/software/Java/kafka1/config
>vi server.properties
修改如下配置:
broker.id=1
listerners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs-1
zookeeper.connect=127.0.0.1:2181
6.修改kafka2配置文件:
>cd /usr/local/software/Java/kafka2/config
>vi server.properties
修改如下:
broker.id=2
listerners=PLAINTEXT://:9093
log.dirs=/tmp/kafka-logs-2
7.修改kafka3配置文件:
>cd /usr/local/software/Java/kafka3/config
>vi server.properties
修改如下:
broker.id=3
listerners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs-3
8.安装zookeeper并启动(网上教程很多)
>cd zk安装目录/bin
>./zkServer.sh start
9.集群启动:在命令后添加-daemon参数,可以使kafka以守护进程方式启动,即不占用窗口
启动kafka1:
>cd /usr/local/software/Java/kafka1/bin/
>./kafka-server-start.sh -daemon ../config/server.properties
启动kafka2:
>cd /usr/local/software/Java/kafka2/bin/
>./kafka-server-start.sh -daemon ../config/server.properties
启动kafka3:
>cd /usr/local/software/Java/kafka3/bin/
>./kafka-server-start.sh -daemon ../config/server.properties
10.通过zk客户端查看kafka在zk中的元数据信息:
>cd /zk安装目录/bin
>./zkCli.sh -server localhost:2181
>ls /brokers/ids