카프카를 사용하여 스프링 클라우드 스트림에 멱등 원 제작자를 어떻게 설정할 수 있습니까?

Question

카프카 0.11에서 소개 된 멱등갑 제작자를 활용하고 싶습니다.

멱등 : 정확히-번 파티션

당 주문 의미에서

을 당 정확히 한 번만 의미를이 기능을 켜고 얻으려면 파티션 의미없는이 Confluent blog post에 따르면 새로운 속성은이를 지원하기 위해 추가되었다 중복, 데이터 손실 없음 및 순서대로 의미 - 제작자를 구성하여 "enable.idempotence = true"로 설정합니다.

포인트는 해당 속성의 사용에 대한 Spring Cloud Stream이나 Spring Kafka 문서가 아닙니다. Spring Cloud Stream 어플리케이션에서 어떻게 구성 할 수 있습니까?

Answer 1

임의의 카프카 속성은 spring.cloud.stream.kafka.bindings.<channel>.producer.configuration을 사용하여 documented here으로 설정할 수 있습니다.

그래서 속성을 설정하기 만하면됩니다.

물론 Ditmars 릴리스 트레인 release notes에서 설명한대로 kafka11 아티팩트를 사용하려면 기본 카프카 바인더를 덮어 써야합니다.

kafka11 바인더도 트랜잭션을 지원합니다.