Kafka -> ES/HDFS with Logstash or Kafka Stream/Connect