本文目的:
1.搭建kafka集群
2.安装kafka控制台
kafka中间件使用Scala语言开发的,运行在JVM上,所以需要安装JDK,由于下载源码需要安装编译环境进行编译,相对麻烦,所以这里直接用可执行的文件进行安装,然后kafka是依赖zookeeper的,所以也要运行kafka也需要安装zookeeper。
分别下载kafka版本--2.11-1.1.0和zookeeper版本--3.5.6并解压到服务器。
1.zookeeper启动
zookeeper可搭建集群,也可单机启动,修改配置文件即可,这里以单击形式启动
cd /zk/bin
./zkServer.sh start ../conf/zoo.conf
2.kafka启动(伪集群)
复制配置文件
cd /kafka/conf
cp server.properties server-1.properties
cp server.properties server-2.properties
修改配置文件
修改broker.id,listeners,log.dir这三个参数
启动集群
cd /kafka/bin
./kafka-server-start.sh -daemon ../config/server.properties
./kafka-server-start.sh -daemon ../config/server-1.properties
./kafka-server-start.sh -daemon ../config/server-2.properties
3.kafka控制台安装(kafka-manager)
下载编译好的安装包,并解压
链接:https://pan.baidu.com/s/1qYifoa4 密码:el4o
修改配置
cd /conf
vi application.conf
kafka-manager.zkhosts="localhost:2181"
如果是集群修改为集群地址即可
启动
bin/kafka-manager
kafka-manager 默认的端口是9000,可通过 -Dhttp.port,指定端口; -Dconfig.file=conf/application.conf指定配置文件:
nohup bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080 &