input {
    kafka {
            bootstrap_servers => "localhost:9092"
            topics => ["tas-logs"]
    }
} 

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

output {
   elasticsearch {
      hosts => ["127.0.0.1:9200"]
      index => "tas-logs-%{+YYYY.MM.dd}"
      workers => 1
      ssl => true
      ssl_certificate_verification => false
      user => '{YOUR_USERNAME}'
      password => '{YOUR_PASSWORD}'
      codec => "json"
    }
}