2 Home
gitea_admin edited this page 2026-03-11 14:44:40 +00:00

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>