juplo.de Git - demos/kafka/deduplication/blob - src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformerSupplier.java

   1 package de.juplo.demo.kafka.deduplication;
   2
   3 import org.apache.kafka.streams.kstream.ValueTransformerWithKey;
   4 import org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier;
   5
   6
   7 public class DeduplicationTransformerSupplier<K, V> implements ValueTransformerWithKeySupplier<K, V, Iterable<V>>
   8 {
   9   SequenceNumberExtractor<K, V> extractor;
  10
  11
  12   public DeduplicationTransformerSupplier(SequenceNumberExtractor<K, V> extractor)
  13   {
  14     this.extractor = extractor;
  15   }
  16
  17
  18   @Override
  19   public ValueTransformerWithKey<K, V, Iterable<V>> get()
  20   {
  21     return new DeduplicationTransformer<K, V>(extractor);
  22   }
  23 }