MaplStream with spring integration 카프카 제작자 문제

Question

저는 스프링 통합으로 mapr-stream을 사용하고 maprstream 주제에 메시지를 보내기 위해 게시자를 만들려고합니다. here을 언급 한 아래 Jar 버전 호환성 매트릭스를 사용하고 있습니다.

봄 - 통합 - 카프카 - 2.0.1.RELEASE
봄 - 카프카 - 1.0.3.RELEASE
카프카 - 클라이언트 - 0.9.0.0 - mapr - 1607 년 봄에 언급 한 바와 같이

내가 봄 - 통합 - 카프카-2.0.1 항아리, 를 사용하고 있지만이 '동기'를 말하는 스키마 검증 문제를 얻고 경우 통합 카프카 documentation, 나는 KafkaProducerMessageHandler에서 속성 '동기'을 설정 할 수 있어야한다 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); 
}