kafka集群搭建

1.前提:安装zookeeper

可以参考https://blog.csdn.net/qq_43338182/article/details/85340577

2.安装kafka

1.下载,解压,改名(kafka)略

我使用的是:kafka_2.11-0.10.2.1.tgz

2.修改配置文件

vim /usr/local/kafka/config/server.properties
kafka集群搭建
其他主机的 broker.id 依次 1 2
listeners:是那台主机就写那台主机的 IP
kafka集群搭建
这个其他主机都一样(我这里还是配了hosts:读者可以直接写 ip:端口)

3.启动
端口一定要放开,我栽了好几次坑了

cd /usr/local/kafka
./bin/kafka-server-start.sh -daemon config/server.properties

4.验证
集群都启动以后:看看是否都启动了;

ps -ef | grep kafka

添加一个主题:

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper hserver1:2181 --replication-factor 3 --partitions 3 --topic test

–zookeeper : zookeeperd主机ip+端口
–replication-factor : 几个节点就写几
–topic : 主题名

5.使用工具连接
修改windows中的 hosts文件中添加:
hosts文件路径:C:\Windows\System32\drivers\etc
kafka集群搭建
kafka集群搭建
kafka集群搭建