}
String topic = "topic-" + topicSampler.sample();
String message = "m-" + (++messageId);
client.sendMessage(topic, message);
recorder.message(topic);
log.debug("Sent {} / {}", topic, message);
if ((messageId % 10000) == 0) {
log.warn("Sent {} messages", messageId);
}
}