This is a demo project that shows an end-to-end workflow of ingesting streaming data in via NiFi, putting it into a Kafka queue, reading that Kafka queue with Druid, and finally monitoring a custom Python/Flask dashboard for errors. You can additionally use Superset to visualize the data in Druid by creating your own dashboards. The project generates sample data in two possible domains: automotive part production data or POS transactions.
Instructions on deployment and configuration are contained in the repo, as well as more detail on context and purpose.
