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>
Sat, 10 Oct 2020 19:30:12 +0000 (21:30 +0200)
commit5bb3d2908ccfe091084aa8a0a8b1282fb19fb3e1
tree9b5bb289e085e2b734c0173adebd48946bdd1821
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]