String username = (String)entry.get("username");
String event = username + ":" + type.name();
+ LOG.debug("Sending event {} ({})", id, event);
+
ProducerRecord<Long, String> record = new ProducerRecord<>(topic, id, event);
producer.send(record, (metadata, e) -> {
if (e != null) {