A poc to send fake timeseries data via kafka to be stored in a Db . And then Airflow dag runs on that data.