KafkaProducer.java 文件源码

@Scheduled(fixedDelay = 7000)
public void sendNewApoyo() {
    String comentarioJSON = "";
    comentario = randomGenerator.newComentario();
    comentario.setTexto("");

    try {
        comentarioJSON = mapper.writeValueAsString(comentario);
        send("apoyos", comentarioJSON);
    } catch (JsonProcessingException e) {
        e.printStackTrace();
    }
}