什麼是Camel KafkaIdempotentRepository及其用途？

Question

我試圖獲得與卡夫卡最新的偏移量味精。這可以用來得到它嗎？ 'KafkaIdempotentRepository' 如果不是它有什麼用處呢？

在java文檔中它說明了以下內容。但目前尚不清楚它的真正用途。

Answer 1

駱駝冪等存儲庫實現被用作消費者濾除重複的消息。 KafkaIdempotentRepository是Camel提供的許多實現之一（例如，其他的是MemoryIdempotentRepository，FileIdempotentRepository，HazelcastIdempotentRepository，JCacheIdempotentRepository，InfinispanIdempotentRepository等）。

有關詳細閱讀請參考以下鏈接：

https://access.redhat.com/documentation/en-US/Red_Hat_JBoss_Fuse/6.2/html/Apache_Camel_Development_Guide/MsgEnd-Idempotent.html

http://people.apache.org/~dkulp/camel/idempotent-consumer.html

回到你的問題：

我試圖獲得與味精卡夫卡的最新抵消額。這可以用來得到它嗎？ 'KafkaIdempotentRepository'如果不是有什麼用處呢？

我個人認爲，我不認爲KafkaIdempotentRepository是爲了服務這個用例。

Kafka確保排序，這意味着消息服務將在分區內具有最新的提交偏移量。