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 startu
Updated 2026-03-17 20:53:02 +00:00
Replace the Kafka record key with a new key formed from a fields subset coming from the message body
Updated 2026-03-11 14:31:24 +00:00
Filter based on kafka topic value compared to regex
Updated 2026-03-11 14:31:20 +00:00
Update the topic field as a function of the original topic name and the record timestamp.
Updated 2026-03-11 14:31:20 +00:00
|-
Updated 2026-03-11 14:31:16 +00:00
Update the destination using the configured regular expression and replacement string
Updated 2026-03-11 14:31:14 +00:00
Update the topic field as a function of the original topic name and the record's timestamp field.
Updated 2026-03-11 14:31:09 +00:00
|-
Updated 2026-03-11 14:31:07 +00:00
|-
Updated 2026-03-11 14:31:07 +00:00
|-
Updated 2026-03-11 14:31:07 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:06 +00:00
|-
Updated 2026-03-11 14:31:05 +00:00
|-
Updated 2026-03-11 14:31:05 +00:00
|-
Updated 2026-03-11 14:31:05 +00:00