ProfileEventProducer.java 文件源码

/**
 * Send event to kafka.
 * @param content the event data
 */
@Async
public void send(String content) {
    if (StringUtils.isNoneBlank(content)) {
        log.debug("Sending kafka event with data {} to topic {}", content, topicName);
        template.send(topicName, content);
    }
}