MaprStream with spring integration Kafka Producer issue

0
votes

I am using mapr-stream with spring integration and trying to create a publisher to send messages to maprstream topics. I am using the below Jar version compatibility matrix mentioned here.

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

As mentioned in the spring integration Kafka documentation, I should be able to set the property 'sync' in KafkaProducerMessageHandler if I am using spring-integration-kafka-2.0.1 jar, but I am getting the schema validation issues saying the 'sync' is not expected in the KafkaProducerMessageHandler.

Could someone please help me on this?

1
springspring-integrationspring-kafkamapr-streams

1 Answers

1
votes

XML Namespace support for sync was not added until 2.1.

With 2.0.x, you have to set the property on the KafkaProducerMessageHandler bean programmatically.

EDIT

@Autowired
private KafkaProducerMessageHandler handler;

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