X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdeduplication;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fdemo%2Fkafka%2Fdeduplication%2FDeduplicationTransformer.java;h=24946724ffabd89ca07bbd061844d5265e4242c0;hp=dc888bcc81026b2c95a9b979f14facf5ee4ada77;hb=refs%2Fheads%2Fmaster;hpb=150907d53cc99a98f4c888eacff892380ffd0feb diff --git a/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformer.java b/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformer.java index dc888bc..2494672 100644 --- a/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformer.java +++ b/src/main/java/de/juplo/demo/kafka/deduplication/DeduplicationTransformer.java @@ -1,7 +1,6 @@ package de.juplo.demo.kafka.deduplication; import lombok.extern.slf4j.Slf4j; -import org.apache.kafka.common.header.Headers; import org.apache.kafka.streams.kstream.ValueTransformer; import org.apache.kafka.streams.processor.ProcessorContext; import org.apache.kafka.streams.state.KeyValueStore; @@ -28,11 +27,7 @@ public class DeduplicationTransformer implements ValueTransformer transform(String value) { - String topic = context.topic(); Integer partition = context.partition(); - long offset = context.offset(); - Headers headers = context.headers(); - long sequenceNumber = Long.parseLong(value); Long seen = store.get(partition);