启动多个进程收集日志。直接output到kafka,output到不同的topic
cat filebeat.yml
filebeat.prospectors:
- input_type: log

paths:

- /home/test/job/logs/job-20*.log
document_type: job
tail_files: true
multiline.pattern: ^\[[0-9]{4}-[0-9]{2}-[0-9]{2}

multiline.negate: true

multiline.match: after

output.kafka:

hosts: ["192.168.1.99:9092"]
topic: job
partition.round_robin:
reachable_only: false

required_acks: 1
compression: gzip
max_message_bytes: 1000000
通过logstash节点会实时去kafka broker集群拉数据,转ES
[root@centos199 config]# cat job.conf
input {
kafka {
bootstrap_servers => "192.168.1.99:9092"
topics => ["job"]
codec => "json"
}
}
output {
elasticsearch {
hosts => ["192.168.1.99:9200"]
index => "job-%{+YYYY.MM.dd}"
template_overwrite => true
}
}

转载于:https://www.cnblogs.com/haoge92/p/9317903.html

ELK之filebeat、logstash多个topic配置相关推荐

  1. ELK实战(一)Filebeat+Logstash发送Email告警日志(1)

    ELK实战(一)Filebeat+Logstash发送Email告警日志(1) ELK应用案例 典型ELK应用架构 本次我使用的架构(Filebeat+Logstash发送Email告警日志) 使用的 ...

  2. ELK+kafaka+filebeat实现系统日志收集与预警

    ELK+kafaka+filebeat实现系统日志收集与预警 总体的流程图如下 1.项目准备 添加相关依赖 <dependencies><dependency><grou ...

  3. filebeat + logstash 发送日志至kafka 入门

    filebeat 官方文档 配置文件 filebeat.yml filebeat.inputs:# Each - is an input. Most options can be set at the ...

  4. filebeat+logstash收集错误日志发送邮件提醒

    filebeat+logstash收集错误日志发送邮件提醒 典型ELK应用架构 因为只收集错误日志并且数据量并不是非常大所以简化流程 使用filebeat+logstash发送异常日志 软件 版本 说 ...

  5. 日志分析管理系统ELK+redis+filebeat搭建

    日志分析平台建设方案 1.建设原因 日志文件分散在各个应用服务器,人员需要远程登录才能查看日志,不利于服务器安全管控,加大服务器的风险 各服务器日志配置不统一,分布杂乱,需要进行规范与管理 日志文件信 ...

  6. 基于filebeat + logstash的日志收集方案

    日志收集是一个很普遍的需求,各个服务的log日志,打点日志都需要收集起来做离线etl或实时分析.日志收集工具也有很多开源的可供选择,flume,  logstash, filebeat等等.  目前3 ...

  7. ELK部署+filebeat应用

    系统配置:CentOS Linux release 7.6.1810 (2核1536M,机器配置问题,容易踩很多坑,特别是低配置,jvm参数可能需要去调整,不然起不来) ELK版本:7.10.2 el ...

  8. 企业级日志分析系统ELK(Elasticsearch , Logstash, Kibana)

    企业级日志分析系统ELK(Elasticsearch , Logstash, Kibana) 前言 一.ELK概述 1.ELK日志分析系统 2.ELK日志处理特点 3.Elasticsearch概述 ...

  9. Centos7下使用ELK(Elasticsearch + Logstash + Kibana)搭建日志集中分析平台

    Centos7下使用ELK(Elasticsearch + Logstash + Kibana)搭建日志集中分析平台 日志监控和分析在保障业务稳定运行时,起到了很重要的作用,不过一般情况下日志都分散在 ...

最新文章

  1. myeclipse使用太卡问题
  2. C# TextBox改变高度的方法(转载)
  3. STL之deque详解
  4. LeetCode 1634. 求两个多项式链表的和
  5. 59. web 攻击技术(3)
  6. c++比c快?一道字符串题目
  7. hello linux
  8. html表单php比较三个值大小,php比较多维数组中值的大小排...-array_filter()函数去掉多维数组...-php生成静态html文件的三种方法_169IT.COM...
  9. 交通分配四阶段法(一)
  10. HTML5项目实战之旅行社网站——移动端流体布局
  11. 上传文件到服务器速度慢怎么解决,网络上传速度慢怎么办(解读其上传速度慢原由)...
  12. python中的translate函数_Python:内置函数makestrans()、translate()
  13. 一名菜鸟程序员的跳槽经历以及其所感所想(二)
  14. 5.larval 验证规则
  15. 我替一位仁兄改的n进制数相加的问题
  16. Windows系统环境编写DOS批处理文件
  17. 亲身体验:八款知名虚拟主机对比测评
  18. App原型图设计工具使用对比
  19. 记录使用 Vue 过程中遇到的一些技术点
  20. 会计假设、会计要素、借贷记账法、会计科目和会计账户

热门文章

  1. Winform巧用窗体设计完成弹窗数值绑定-以重命名弹窗为例
  2. Jquery中使用ajax请求SSM后台时提示:org.springframework.http.converter.HttpMessageNotReadableException: Could no
  3. 如何在Flutter(2021)中创建过滤器搜索列表视图
  4. 全国计算机等级考试三级历年真题,历年全国计算机等级考试三级(数据库技术)笔试选择真题...
  5. 全国计算机等级考试一级教程讲义资料,计算机等级考试一级教程讲义.docx
  6. cx+oracle+sql含中文,sql 判断字段值是是否包含中文字符
  7. 神策数据联合Ping++,推出电商、O2O 行业的 GMV 增长研讨
  8. Silverlight 4 新特性之Silverlight as Drop Target
  9. HTML5 Canvas 绘制旋转45度佛教万字
  10. shell-----函数库调用