zookeeper+kafka安装

1.环境：三台liunx7的虚拟机两核
1.关闭防火墙，seten

传入jdk包，并且安装jdk环境（三台都安装）

记着查看一下有没有安装成功
3.修改主机名


4.修改配置文件

看看可以ping通

5.上传kafka，zookeeper包

6.解压zookeeper包，移动包


7.查看信息（不用写解释）


8.创建zookeeper存放路径



9.启动

10.查看（起不来可以多起几次）



如果报错，可以先同步一下时间
Ntpdate cn.pool.ntp.org
解压kafka，移动kafka

修改配置文件




第二台修改的



第三台



查看一下（我查看的是第二台上的）

启动

查看日志

创建topics（这个在一台虚拟机上创建就行了）


#–replication-factor 2 复制2份
#–partitions 3 创建3个分区
#–topic mag 主题为mag
这里关防火墙
查看是否创建成功

模拟一个producter：生产者（还是这一台虚拟机）


模拟一个consumer:消费者（另一台虚拟机）

上传filebeat包

安装filebeat（在一台上安装就ok了，安装在生产者那一台）

修改配置文件（这里的message修改为messages）


启动filebeat

查看日志

查看进程

去消费者那里查看一下


安装logstash（在一台安装，第二台）

修改配置文件

安装elasticsearch（在一台安装第二台）

修改配置文件





启动elasticsearch，开启自启

查看elasticsearch日志

启动logstash，查看logstash日志


安装kibana（在一台安装第二台）

修改配置文件


这个是elasticsearch的IP地址

测试页面

如果出不来就模拟一下




修改一下时间