filebeat.prospectors:
- input_type: log
  paths:
    - /Data/logs/bigdata/debug.log
  tags: ["trace_debug"]
  document_type: trace_debug
  tail_files: true
  multiline.pattern: '^\['
  multiline.negate: true
  multiline.match: after
output.kafka:
  enabled: true
  hosts: ["{{ kafka_hosts }}"]
  topic: '%{[type]}'
  compression: snappy
  max_message_bytes: 10000000
  worker: 2