我想利用Kafka0.11中引入的幂等生产者。根据这篇合流博客文章，添加了一个新属性来支持这一点：
幂等性：每个分区只有一次顺序语义
要启用此功能并在每个分区中只获取一次语义，即不重复、不丢失数据，并且为了语义，请将生产者配置为设置“enable.idempotence=true”。
这一点既不是springcloudstream，也不是springkafka文档对该属性的使用。我们如何在spring云流应用程序中配置它？
我想利用Kafka0.11中引入的幂等生产者。根据这篇合流博客文章，添加了一个新属性来支持这一点：
幂等性：每个分区只有一次顺序语义
要启用此功能并在每个分区中只获取一次语义，即不重复、不丢失数据，并且为了语义，请将生产者配置为设置“enable.idempotence=true”。
这一点既不是springcloudstream，也不是springkafka文档对该属性的使用。我们如何在spring云流应用程序中配置它？
1条答案
按热度按时间siotufzp1#
可以使用
spring.cloud.stream.kafka.bindings.<channel>.producer.configuration，如本文所述。所以，只需在那里设置属性。
当然，您将需要重写默认的kafka绑定器来使用kafka11工件，正如在ditmars发行说明中所讨论的那样。
kafka11活页夹还支持事务。