Sent messages are deleted individually after a crash

[demos/kafka/outbox] / delivery / src / main / java / de / juplo / kafka / outbox / delivery / Watermarks.java

diff --git a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/Watermarks.java b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/Watermarks.java
deleted file mode 100644 (file)
index 4bd0c9e..0000000
--- a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/Watermarks.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package de.juplo.kafka.outbox.delivery;
-
-
-public class Watermarks
-{
-  private final long[] watermarks;
-
-
-  public Watermarks(int partitions)
-  {
-    watermarks = new long[partitions];
-  }
-
-
-  public synchronized void set(int partition, long watermark)
-  {
-    watermarks[partition] = watermark;
-  }
-
-  public synchronized long getLowest()
-  {
-    long lowest = Long.MAX_VALUE;
-
-    for (int i = 0; i < watermarks.length; i++)
-      if (watermarks[i] < lowest)
-        lowest = watermarks[i];
-
-    return lowest;
-  }
-
-  @Override
-  public String toString()
-  {
-    StringBuilder builder = new StringBuilder();
-    for (int i = 0; i < watermarks.length; i++)
-    {
-      builder.append("partition[");
-      builder.append(i);
-      builder.append("]=");
-      builder.append(watermarks[i]);
-      if (i != watermarks.length - 1)
-        builder.append(", ");
-    }
-    return builder.toString();
-  }
-}