Python program to execute commands and provide status through json messages for MIDAS using Kafka topics