fhussonnois

group 'org.example'
version '1.0'

buildscript {
    repositories {
        jcenter()
    }
    dependencies {
        classpath 'com.github.jengelman.gradle.plugins:shadow:6.1.0'
    }

fhussonnois

package example;

import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.Topology;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.kstream.Produced;

fhussonnois

public class DeduplicationTransformer<K, V, E> implements ValueTransformerWithKey<K, V, V> {

    private ProcessorContext context;

    private WindowStore<E, Long> eventIdStore;

    private final String storeName;

    private final KeyValueMapper<K, V, E> idExtractor;