zoukankan      html  css  js  c++  java
  • logstash-配置文件详解

     
    • kafka  将 kafka topic 中的数据读取为事件
       
      kafka{
      bootstrap_servers=> "kafka01:9092,kafka02:9092,kafka03:9092"
      topics => ["access_log"]
      group_id => "logstash-file"
      codec => "json"
      }
      kafka{
      bootstrap_servers=> "kafka01:9092,kafka02:9092,kafka03:9092"
      topics => ["weixin_log","user_log"]
      codec => "json"
      }
      # bootstrap_servers 用于建立群集初始连接的Kafka实例的URL列表。
      # topics 要订阅的主题列表,kafka topics
      # group_id 消费者所属组的标识符,默认为logstash。kafka中一个主题的消息将通过相同的方式分发到Logstash的group_id
      # codec 通用选项,用于输入数据的编解码器。
  • 相关阅读:
    L7-1 文本处理
    L6-14 继承多态
    L6-13 魔法方法
    L6-12 类的实例
    L6-11 综合运用
    L6-2 嵌套循环
    golang 关于引用类型
    golang close for channel
    go tip
    vscode官方文档
  • 原文地址:https://www.cnblogs.com/brady-wang/p/13741957.html
Copyright © 2011-2022 走看看