A deduplicator, that assumes steadily increasing global sequnece numbers
authorKai Moritz <kai@juplo.de>
Thu, 8 Oct 2020 16:44:06 +0000 (18:44 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 5 May 2024 05:47:30 +0000 (07:47 +0200)
commit0ce7fc1d4688f5ebf04a82124265df741cef6dd3
tree5c951ef887544ff026ace46e770f853b388f9607
A deduplicator, that assumes steadily increasing global sequnece numbers
12 files changed:
.dockerignore [new file with mode: 0644]
.gitignore [new file with mode: 0644]
Dockerfile [new file with mode: 0644]
README.sh [new file with mode: 0755]
create-data.sh [new file with mode: 0755]
docker-compose.yml [new file with mode: 0644]
pom.xml [new file with mode: 0644]
src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformer.java [new file with mode: 0644]
src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformerSupplier.java [new file with mode: 0644]
src/main/java/de/juplo/demo/kafka/deduplication/Deduplicator.java [new file with mode: 0644]
src/main/java/de/juplo/demo/kafka/deduplication/SequenceNumberExtractor.java [new file with mode: 0644]
src/main/java/de/juplo/demo/kafka/deduplication/StreamsDeduplicatorApplication.java [new file with mode: 0644]