spring cloud stream kafka:获取processor.output().send(message)的确认信息;

dgiusagp  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(512)

我想知道《写给Kafka》的主题在《Spring的云流》中是否成功。

public boolean writeToKafka(String emails) {

        Message<String> message = MessageBuilder.withPayload(emails).build();
        return processor.output().send(message);

    }

return语句的计算结果总是true。我需要发回ack给调用方法是否写了消息。

cx6n0qe3

cx6n0qe31#

谢谢格雷·拉塞尔的回答。我刚刚在application.properties中添加了以下属性

spring.cloud.stream.kafka.bindings.output.producer.sync=true

相关问题