KafkaIdempotentRepository

KafkaIdempotentRepository

我正在尝试在kafka中获取具有最新偏移量的味精。可以用来获取吗? 'KafkaIdempotentRepository'
如果没有,它有什么用?

在Java文档中,它表示以下内容。但尚不清楚它的真正用途是什么。

java - 什么是Camel KafkaIdempotentRepository及其用途?-LMLPHP

最佳答案

骆驼幂等存储库实现用作使用者以过滤出重复的消息。 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

回到您的问题:


  我正在尝试在kafka中获取具有最新偏移量的味精。可以用来获取吗? 'KafkaIdempotentRepository'如果没有,它的用途是什么?


以我个人的观点,我认为KafkaIdempotentRepository不适合用于该用例。

Kafka确实保证排序,这意味着所发送的消息将在分区中具有最新的提交偏移量。

09-05 10:51