logstash读取kafka的topics,根据内容提取指定字段然后自动创建es索引。

input {
  kafka{
     bootstrap_servers => "192.168.1.15:9092"
     auto_offset_reset => "latest"
     topics_pattern => "svc.*" #topics_pattern支持正则匹配,topics不支持
     consumer_threads => 5
     codec => "json"
  }

}
filter {
    mutate {
#        gsub => [
#          "fieldname", "#", "-"
#        ] 用于替换指定字符
        split => ["message","#"]          #分割字符串获取服务名
        add_field => {  "service" => "%{[message][3]}" }
    }        
   #下面移除不必要的字段
    mutate {
    remove_field => ["@version"]
    remove_field => ["@timestamp"]
    remove_field => ["tags"]
    remove_field => ["_id"]
    remove_field => ["_type"]
    remove_field => ["_index"]
    remove_field => ["_score"]

}

}

output {
       elasticsearch{  
            hosts => "192.168.1.15:9200" 
            index => "log-%{service}"  
        }
        stdout {
            codec => rubydebug
        }
}

logstash读取kafka所有topics 自动创建es 索引相关推荐

  1. oracle 创建clob类型字段的索引,LOB字段相关概念(自动创建LOB索引段和重建索引方法)...

    LOBs,或Large Objects字段,是Oracle中用于处理存储非字符数据推荐的一种字段类型,例如mp3,video,图片,和long字符串数据.二进制大对象,或BLOBs,字符大对象,或CL ...

  2. java 索引实现,Java创建ES索引实现

    标签:public   text   cluster   frame   put   elastics   sea   min   user 1.pom.xml文件 org.springframewo ...

  3. LOB字段相关概念(自动创建LOB索引段和重建索引方法)

    LOBs,或Large Objects字段,是Oracle中用于处理存储非字符数据推荐的一种字段类型,例如mp3,video,图片,和long字符串数据.二进制大对象,或BLOBs,字符大对象,或CL ...

  4. oracle中LOB字段相关概念(自动创建LOB索引段和重建索引方法)

    OBs,或Large Objects字段,是Oracle中用于处理存储非字符数据推荐的一种字段类型,例如mp3,video,图片,和long字符串数据.二进制大对象,或BLOBs,字符大对象,或CLO ...

  5. Logstash读取Kafka数据写入HDFS详解

    强大的功能,丰富的插件,让logstash在数据处理的行列中出类拔萃 通常日志数据除了要入ES提供实时展示和简单统计外,还需要写入大数据集群来提供更为深入的逻辑处理,前边几篇ELK的文章介绍过利用lo ...

  6. ElasticSearch 根据环境自动创建动态索引

    我的客户端的版本是7.13.0,对应springboot与spring-data-elasticsearch的版本如下:(2.5.8与4.2.7) 引入依赖: <dependency>&l ...

  7. 怎样合理创建es索引_如何通过Elasticsearch创建索引库?

    今天是刘小爱自学Java的第158天. 感谢你的观看,谢谢你. 学习计划安排如下:Elasticsearch作为一门全文检索技术,那它是如何使用的呢? 先学习Elasticsearch的一些语法,后续 ...

  8. kibana创建es索引_java操作es动态创建索引(按月生成),索引类型,索引别名

    第一步:判断索引是否存在: //判断索引是否已经存在String indexName = Constans.ES_INDEX_TIME+"_"+DateUtils.getDateS ...

  9. kibana创建es索引_es 索引数据创建mapping 普通内部对象 嵌套文档 父子文档创建和查询...

    普通内部对象 "kibana_sample_data_ecommerce" : { "mappings" : { "properties" ...

最新文章

  1. java 解析证书_java 读取证书类以及key tool gui 1.7
  2. C++入门经典-例9.4-默认模板参数
  3. java中常见的异常类
  4. Bug : Bash on Ubuntu on Windows scp work on window but not in shell file
  5. 用 JavaScript 操作字符串
  6. java 导出bcp文件格式_使用BCP导出导入数据
  7. Flutter社区和资源传送门
  8. NVisionXR_iOS教程十一 —— 多场景切换
  9. mmap和MappedByteBuffer
  10. 未定义jm matlab,math – 使用Jm 1 = 2mj(m)-j(m-1)公式在MATLAB中计算bessel函数
  11. python如何上传文件_python请求文件上传
  12. 怎样用关系代数表达式表示查询要求?求过程
  13. 手机及电脑抓包(tcp,udp,http)
  14. Docker理论与实践(四)
  15. cron表达式 每个月的最后一个工作日的另一种解法
  16. 计算机硬件中内存的作用是什么,内存是什么 内存条的作用到底是什么
  17. 彻底删除微软拼音输入法
  18. 宽带连接工具[bat]
  19. 《阴阳师》RPG游戏体验报告
  20. bps、Bps、pps的概念和区别

热门文章

  1. JQuery拖拽通过八个点改变div大小
  2. 在Keil MDK编译环境下使用UEstudio编写程序
  3. 计算机小白如何真正入门计算机?
  4. android 11.0 12.0USB连接模式默认设为MTP
  5. ISO 18184纺织品抗病毒活性的测定
  6. 整合一些我认知的几种编程语言
  7. 基于QT(c++)的家庭财务管理系统
  8. html 中圆角怎么写,html中的圆角
  9. 【目标流畅阅读文献_语法篇】1.3简单句_动词时态
  10. 非企用户该如何推广?什么事非企户呢?