MaprStream 与 Spring 集成 Kafka Producer 问题

Question

我正在使用带有 spring 集成的 mapr-stream 并尝试创建一个发布者来向 maprstream 主题发送消息。我正在使用下面提到的 Jar 版本兼容性矩阵 here。

Spring-integration-kafka - 2.0.1.RELEASE
Spring-Kafka - 1.0.3.RELEASE
Kafka-clients - 0.9.0.0-mapr-1607

正如 spring 集成 Kafka documentation 中所述，如果我使用 spring-integration-kafka-2.0.1，我应该能够在 KafkaProducerMessageHandler 中设置属性“sync” 罐子， 但我收到架构验证问题，说 KafkaProducerMessageHandler 中不需要“同步”。

有人可以帮我解决这个问题吗？

Answer 1

sync 的 XML 命名空间支持为 not added until 2.1。

对于 2.0.x，您必须以编程方式设置 KafkaProducerMessageHandler bean 的属性。

编辑

@Autowired
private KafkaProducerMessageHandler handler;

@PostConstruct
public void init() {
    this.handler.setSync(true);
}