- #To Do - Add producer
- #self.producer.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)
- self.producer.publish(topic=topic, messages=json.dumps(response_msg), msg_key=msg_key)
+ self.logger.info("Publishing response:\nTopic={}\nKey={}\nValue={}"\
+ .format(topic, msg_key, response_msg))
+ #Core Add producer
+ self.producer_access_credentials.publish(key=msg_key, value=json.dumps(response_msg), topic=topic)