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
其他主机的 broker.id 依次 1 2
listeners:是那台主机就写那台主机的 IP
这个其他主机都一样(我这里还是配了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