1 package de.juplo.kafka.outbox.delivery;
4 public class Watermarks
6 private final long[] watermarks;
9 public Watermarks(int partitions)
11 watermarks = new long[partitions];
15 public synchronized void set(int partition, long watermark)
17 watermarks[partition] = watermark;
20 public synchronized long getLowest()
22 long lowest = Long.MAX_VALUE;
24 for (int i = 0; i < watermarks.length; i++)
25 if (watermarks[i] < lowest)
26 lowest = watermarks[i];
32 public String toString()
34 StringBuilder builder = new StringBuilder();
35 for (int i = 0; i < watermarks.length; i++)
37 builder.append("partition[");
40 builder.append(watermarks[i]);
41 if (i != watermarks.length - 1)
44 return builder.toString();