Kafka Idempotent Repository
Idempotent repository that uses Kafka to store message ids. Uses a local cache of previously seen Message IDs. The topic used must be unique per logical repository (i.e. two routes de-duplicate using different repositories, and different topics) On startup, the instance consumes the full content of the topic, rebuilding the cache to the latest state.
Metadata
| Property |
Value |
| Interface Type |
org.apache.camel.spi.IdempotentRepository |
| Version |
4.10.2 |
Maven Dependency
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-kafka</artifactId>
<version>4.10.2</version>
</dependency>