我正在使用带有 spring 集成的 mapr-stream 并尝试创建一个发布者来向 maprstream 主题发送消息。我正在使用这里提到的以下 Jar 版本兼容性矩阵。
Spring-integration-kafka - 2.0.1.RELEASE
Spring-Kafka - 1.0.3.RELEASE
Kafka-clients - 0.9.0.0-mapr-1607
如 spring 集成 Kafka文档中所述，如果我使用的是spring-integration-kafka-2.0.1 jar ，我应该能够在 KafkaProducerMessageHandler 中设置属性“ sync ” ，但是我遇到了“同步”的模式验证问题在 KafkaProducerMessageHandler 中不会出现。
有人可以帮我吗？
对XML命名空间的支持sync是不添加到2.1。
对于 2.0.x，您必须以KafkaProducerMessageHandler编程方式在bean上设置属性。
编辑
@Autowired
private KafkaProducerMessageHandler handler;
@PostConstruct
public void init() {
this.handler.setSync(true);
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句