ELK Stack (5)——使用Redis\Kafka作为消息队列减轻压力

当多台Filebeat向Logstash传输数据再交给ES入库时，压力会比较大，可以在Filebeat和Logstash之间加上一层消息队列减轻压力，比如Redis、Kafka（日志量大的时候推荐用Kafka，比较重量级，依赖JDK和Zookeeper）。整个架构就是：Filebeat > Redis\Kafka > Logstash > Elasticsearch > Kibana。

一、ELK架构引入Redis配置步骤

1、首先将Filebeat的输出给到redis中，修改OUTPUT部分：

output:
  redis:
    hosts:["192.168.1.100"]
    port:6379
    password: 'redis_password'
    key: 'log'  #这个key就是将写入redis的key名，list类型

2、登录Redis后通过keys *命令可以看到有了一个key叫做log，这个就是配置文件里设置的key名，使用LLEN demo可以看到该key的长度，input如果输入了100行，那么这个key就应该有100行

3、配置Logstash从Redis中读取数据，修改input部分：

input {
    redis {
        host => "192.168.1.100"  
        port => "6379"  
        db => "0"  
        data_type => "list"
        key => "log" 
        password => 'redis_password'
    }
}

4、所有组件都运行成功后再去redis看看，队列会因为被output到了ES中而消失掉或者是迅速减少长度

二、ELK架构引入Kafka配置步骤

1、安装Zookeeper。因为Kafka需要依赖JDK和Zookeeper，JDK的安装这里略过了。所以先进行Zookeeper的安装。到zookeeper.apache.org下载二进制安装包，解压后即可使用

tar zxf zookeeper-3.4.14.tar.gz
mv zookeeper-3.4.14 /usr/local
#修改ZK的配置文件并启动服务。
cd /usr/local/zookeeper-3.4.14
cp zoo_sample.cfg zoo.cfg
vi zoo.cfg
clientPortAddress=0.0.0.0
clientPort=2181
#启动zk服务
/usr/local/zookeeper-3.4.14/bin/zkServer.sh start

2、安装Kafka。在kafka.apache.org/downloads下载二进制安装包，解压后即可使用

tar zxf kafka_2.11-2.1.1.tgz
mv kafka_2.11-2.1.1 /usr/local/
#修改kafka配置文件
vi config/server.properties
zookeeper.connetc=192.168.1.100:2181  #zk服务地址与端口
listeners=PLAINTEST://192.168.1.100:9092  #kafka监听端口
#后台启动kafka
nohup bin/kafka-server-start.sh config/server.properties &

3、将Filebeat的输出给到kafka中，修改OUTPUT部分

output:
  kafka:
    hosts:["192.168.1.100:9092"]
    topic: log  #写到kafka中的队列标签，可自定义

4、配置Logstash从Redis中读取数据，修改input部分：

input {
    kafka {
        bootstrap_servers => "192.168.1.100:9092"  
        topic => ["log"]
        group_id => "log"
        codec => "plain"  #如果日志是json格式的这里就需要改为json
    }
}

5、查看kafka队列信息

/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 192.168.1.100:9092 --list  #查看Group，应该能看到log这个队列存在

/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 192.168.1.100:9092 --group log --describe  #查看具体的队列和消费信息