1 package de.juplo.kafka.outbox.delivery;
4 public class Watermarks
6 private long[] watermarks = new long[0];
9 public synchronized void set(int partition, long watermark)
11 if (partition >= watermarks.length)
13 long[] resized = new long[partition + 1];
14 for (int i = 0; i < watermarks.length; i++)
15 resized[i] = watermarks[i];
19 watermarks[partition] = watermark;
22 public synchronized long getLowest()
24 long lowest = Long.MAX_VALUE;
26 for (int i = 0; i < watermarks.length; i++)
27 if (watermarks[i] < lowest)
28 lowest = watermarks[i];