Simplified example

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

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