Spring cloud Stream Kafka：获取 processor.output().send(message) 的确认；

Question

我想知道用spring-cloud-stream写入kafka主题是否成功。

public boolean writeToKafka(String emails) {

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

    }

return 语句的计算结果始终为真。我需要将消息发送回调用方法是否已写入。

Answer 1

感谢 Gray Russell 的回答。我刚刚在 application.properties

中添加了以下属性

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

Spring cloud Stream Kafka：获取 processor.output().send(message) 的确认；

Spring cloud Stream Kafka: Get acknowledgement for processor.output().send(message);

apache-kafka

spring-cloud-stream