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

diff --git a/src/main/java/de/juplo/demo/kafka/deduplication/SequenceNumberExtractor.java b/src/main/java/de/juplo/demo/kafka/deduplication/SequenceNumberExtractor.java
deleted file mode 100644
index 8f74c71..0000000
--- a/src/main/java/de/juplo/demo/kafka/deduplication/SequenceNumberExtractor.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package de.juplo.demo.kafka.deduplication;
-
-import org.apache.kafka.common.header.Headers;
-
-
-public interface SequenceNumberExtractor<K,V>
-{
-  /**
-   * Extracts a sequence number from the given value.
-   *
-   * The sequence number must be represented as a {@link Long} value.
-   *
-   * @param topic The topic, the message was issued on
-   * @param partition The partition, the message was written to
-   * @param offset The offset of the message in the partition
-   * @param key The key of the message
-   * @param value The value of the message
-   * @return a unique ID
-   */
-  public long extract(String topic, int partition, long offset, Headers headers, K key, V value);
-}