pipelines:
  http:
    input:
      type: http
      address: ":9400"
      meta:
        remote_addr: "{{ .remote_addr }}"
        user_agent: '{{ index (index .request.Header "User-Agent") 0}}'
        login: "{{ .login }}"

pipelines:
  kafka:
    settings:
      capacity: 128
    input:
      type: kafka
      brokers:
        - localhost:9092
      topics:
        - events
      offset: newest
      meta:
        partition: '{{ .message.Partition }}'
        topic: '{{ .message.Topic }}'
    actions:
    - type: json_decode
      field: message
    output:
      type: stdout