Untitled

input {
  kafka {
    zk_connect => "kafka-1:2181,kafka-2:2181,kafka-3:2181,kafka-4:2181,kafka-5:2181"
    group_id => "foo"
    topic_id => "bar"
    consumer_threads => 4
    codec => plain { format => "%{message}" }
  }
}

filter {
  json {
    source => "message"
  }
}

output {
  elasticsearch {
    host => ["10.240.62.4:9200", "10.240.207.224:9200", "10.240.7.181:9200", "10.240.72.221:9200", "10.240.199.125:9200"]
    protocol => "http"
    workers => 4
  }
}