Connect to a MQTT Broker, Subscribe to a Topic and perform Filtering/Saving of specific records

This code connects to a MQTT Broker , reads message queue subscribing to a topic name , applies filters ( in this case look for a specific message ) and saves matching records to CSV on disk for futher processing in SAP Hana database.