Kafka下载
Kafka官方下载地址:https://kafka.apache.org/downloads
根据自己的需求下载相应版本的Kafka,Kafka是由scala语言编写,下载稳定Scala版本。
如下图所示:
Kafka安装
1.新建Kafka安装目录
命令:
cd / cd /opt mkdir kafka
2.Kafka解压安装包
tar -xzvf 解压包名称
比如:
[root@mikechen kafka]# tar -zxvf kafka_2.12-3.1.0.tgz
然后再查看解压文件:
[root@mikechen kafka]# cd kafka_2.12-3.1.0 [root@mikechen kafka_2.12-3.1.0]# ls bin config libs LICENSE licenses NOTICE site-docs
3.修改核心配置文件
进入config配置目录,修改配置文件 server.properties
cd config
修改配置文件 server.properties:
vi /opt/kafka/config/server.properties
修改如下6处内容:
1)修改kafka配置
#要求每台kafka都有唯一的brokerid broker.id=1 listeners=PLAINTEXT://server1:9092
配置说明:
broker.id :配置的是集群环境,要求每台kafka都有唯一的brokerid;
listeners:listeners配置的是kafka的tcp侦听ip地址;
注:listeners监听器千万不能写localhost,否则虽然在本地可以通信,一旦外网通过JavaAPI访问就会出错。
2)修改日志的位置
log.dirs=/opt/kafka/data
log.dirs :数据存放的目录。
3)修改Zookeeper
zookeeper.connect=server1:2181
如果是集群配置,修改为:
zookeeper.connect=server1:2181,server2:2181,server3:2181
多个zookeeper通过,分割,比如:erver1:2181,server2:2181即可。
4.测试安装
1.启动zookeeper
kafka 是基于 Zookeeper 的消息管理系统,所以启动的时候是需要使用到 Zookeeper ,但其内置了Zookeeper ,所以只需要根据bin目录下的文件进行启动即可。
cd /opt/kafka/bin ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
Zookeeper 启动成功后会出现 binding to port 0.0.0.0/0.0.0.0:2181 所示结果表示启动成功。
2.再启动kafka
进入到kafka bin目录下, 启动如下指令
./kafka-server-start.sh -daemon ../config/server.propertie
3.验证Kafka
命令:
ps -ef|grep kafka
kafka进程存在就说明已经安装成功了。
4.Kafka集群搭建
按照如上的方式,在其他服务器上启动对应的若干个kafka 节点, 就可以组成Kafka集群搭建。
陈睿mikechen
10年+大厂架构经验,资深技术专家,就职于阿里巴巴、淘宝、百度等一线互联网大厂。
关注「mikechen」公众号,获取更多技术干货!
后台回复【面试】即可获取《史上最全阿里Java面试题总结》,后台回复【架构】,即可获取《阿里架构师进阶专题全部合集》