One more thought, if you're "broadcasting" the output of the KafkaSource,
it may as well be the case that some partition is empty?
Best,
D.
On Thu, Dec 2, 2021 at 5:11 PM David Morávek wrote:
> Hi Sweta,
>
> the output timestamp seems reasonable to me. I guess you're concerned
> about watermark
Hi Sweta,
the output timestamp seems reasonable to me. I guess you're concerned about
watermarks you're seeing, is that correct?
final Instant min = Instant.ofEpochMilli(Long.MIN_VALUE);
final Instant max = Instant.ofEpochMilli(Long.MAX_VALUE);
System.out.printf("Min: %s, Max: %s%n", min, max);
