X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdeduplication;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fdemo%2Fkafka%2Fdeduplication%2FDeduplicationTransformerSupplier.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fdemo%2Fkafka%2Fdeduplication%2FDeduplicationTransformerSupplier.java;h=0000000000000000000000000000000000000000;hp=37210e8da19976a6afc4d0da26e3b73f67ff0607;hb=1fc026384b7699a18323b3ca8106bea86f173349;hpb=5bb3d2908ccfe091084aa8a0a8b1282fb19fb3e1

diff --git a/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformerSupplier.java b/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformerSupplier.java
deleted file mode 100644
index 37210e8..0000000
--- a/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformerSupplier.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package de.juplo.demo.kafka.deduplication;
-
-import org.apache.kafka.streams.kstream.ValueTransformerWithKey;
-import org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier;
-
-
-public class DeduplicationTransformerSupplier<K, V> implements ValueTransformerWithKeySupplier<K, V, Iterable<V>>
-{
-  SequenceNumberExtractor<K, V> extractor;
-
-
-  public DeduplicationTransformerSupplier(SequenceNumberExtractor<K, V> extractor)
-  {
-    this.extractor = extractor;
-  }
-
-
-  @Override
-  public ValueTransformerWithKey<K, V, Iterable<V>> get()
-  {
-    return new DeduplicationTransformer<K, V>(extractor);
-  }
-}