Clusters:
- Input:
    Kafka:
      Name: gostash
      Brokers:
        - "192.168.139.129:9092"
      Topics:
        - pushMessage
      Group: pro
      Consumers: 16
  Filters:
    - Action: drop
      Conditions:
        - Key: k8s_container_name
          Value: "-rpc"
          Type: contains
        - Key: level
          Value: info
          Type: match
          Op: and
    - Action: remove_field
      Fields:
        - message
        - _source
        - _type
        - _score
        - _id
        - "@version"
        - topic
        - index
        - beat
        - docker_container
        - offset
        - prospector
        - source
        - stream
    - Action: transfer
      Field: message
      Target: data
  Output:
    Postgresql:
      Host: "192.168.100.102"
      Port: "5432"
      User: "postgres"
      Password: "123456"
      DBName: "mmm_log"