docker-log-centralizer/logstash/shipper/pipeline/beat_kafka.conf

input {
  beats {
    port => 5044
  }
}
output {
  kafka {
    codec => json
    bootstrap_servers => "kafka:9092"
	topic_id => "%{type}"
  }
  stdout {
    codec => rubydebug
  }
}