我正在尝试在kafka中获取具有最新偏移量的味精。可以用来获取吗? 'KafkaIdempotentRepository'
如果没有,它有什么用?
在Java文档中,它表示以下内容。但尚不清楚它的真正用途是什么。
最佳答案
骆驼幂等存储库实现用作使用者以过滤出重复的消息。 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确实保证排序,这意味着所发送的消息将在分区中具有最新的提交偏移量。