Simplified example

[demos/kafka/deduplication] / src / main / java / de / juplo / demo / kafka / deduplication / DeduplicationTransformerSupplier.java

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 (file)
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);
-  }
-}