ELK 日志采集框架:Kafka安装与配置
Posted AusKa_T
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ELK 日志采集框架:Kafka安装与配置相关的知识,希望对你有一定的参考价值。
1 资源
资源信息 | 版本号 | 备注 |
---|---|---|
服务器 | Centos7 | IP: 192.168.51.4 |
JRE | 1.8 | 如果已安装请忽略 |
kafka | 2.12-2.1.0 | IP: 192.168.51.4 |
zookeeper | 3.4.10 | IP: 192.168.51.4 |
2 介绍
Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的分布式日志系统(也可以当做MQ系统),常见可以用于web/nginx日志、访问日志,消息服务等等,Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。
主要应用场景是:日志收集系统和消息系统。
Kafka主要设计目标如下:
- 以时间复杂度为O(1)的方式提供消息持久化能力,即使对TB级以上数据也能保证常数时间的访问性能。
- 高吞吐率。即使在非常廉价的商用机器上也能做到单机支持每秒100K条消息的传输。
- 支持Kafka Server间的消息分区,及分布式消费,同时保证每个partition内的消息顺序传输。
- 同时支持离线数据处理和实时数据处理。
- Scale out:支持在线水平扩展
附上官网地址:http://kafka.apache.org/
3 安装与配置
3.1 安装
kafka单机版的安装,可参考博文:
MQ Kafka单机版部署和配置:xxx
3.2 配置
3.2.1 启动kafka
[root@localhost software]# cd /usr/local/kafka_2.12/bin/
[root@localhost bin]# /usr/local/kafka_2.12/bin/kafka-server-start.sh /usr/local/kafka_2.12/config/server.properties &
3.2.2 创建topic
这里创建的topic,与filebeat.yml的配置信息相对应
[root@localhost bin]# kafka-topics.sh --zookeeper 192.168.51.4:2181 --create --topic app-log-collector --partitions 1 --replication-factor 1
[root@localhost bin]# kafka-topics.sh --zookeeper 192.168.51.4:2181 --create --topic error-log-collector --partitions 1 --replication-factor 1
3.2.3 查看topic列表
[root@localhost bin]# kafka-topics.sh --zookeeper 192.168.51.4:2181 --list
3.2.4 查看topic情况
[root@localhost bin]# kafka-topics.sh --zookeeper 192.168.51.4:2181 --topic app-log-test --describe
4 相关信息
博文不易,辛苦各位猿友点个关注和赞,感谢
以上是关于ELK 日志采集框架:Kafka安装与配置的主要内容,如果未能解决你的问题,请参考以下文章