logstash kafka for aqueducts