Kafkaを使用してSpring Cloud Stream内に冪等元のプロデューサを設定するにはどうすればよいですか？

Question

私はKafka 0.11で紹介された冪等生産者を利用したいと思います。

冪等：必ず1回パーティション

あたりの順セマンティクスでこの機能をオンにすると パーティションを意味していないあたり、正確ワンスセマンティクスを取得するには、この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アーティファクトを使用するには、デフォルトのkafkaバインダーを上書きする必要があります。

kafka11バインダーもトランザクションをサポートしています。