我想知道《写给Kafka》的主题在《Spring的云流》中是否成功。
public boolean writeToKafka(String emails) {
Message<String> message = MessageBuilder.withPayload(emails).build();
return processor.output().send(message);
}
return语句的计算结果总是true。我需要发回ack给调用方法是否写了消息。
1条答案
按热度按时间cx6n0qe31#
谢谢格雷·拉塞尔的回答。我刚刚在application.properties中添加了以下属性