BroadcastListener gets message from tools, publish them to kafka in a fault tolerant and resilient way.