[FULL SOURCE CODE] Realtime Logs Processing with Apache Airflow, Kafka and Elasticsearch