marcodifalco

In this method ``` @Override public void outgoingBroadcast(Object message) { logger.trace("{} outgoingBroadcast {}", topic, message); // TODO: Prevent message round trip. producer.send(new ProducerRecord(topic, message.toString())); } ``` There are not a...