Spring Cloud Stream Kafka: получение подтверждения для процессора.output (). Send (сообщение);

Question

Я хочу знать, была ли запись в kafka успешной с помощью spring-cloud-stream.

public boolean writeToKafka(String emails) {

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

    }

Операторы return всегда оцениваются как true.Мне нужно отправить обратно вызывающему методу подтверждение, было ли написано сообщение.

Answer 1

Спасибо Грей Рассел за ответ.Я только что добавил свойство ниже в application.properties

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