Hi guys, I have a question related to utilizing watermarks with multiple FlinkKakfkaConsumer082 instances. The aim is to have a global watermark across multiple kafka consumers where any message from any kafka partition would update the same watermark. When testing a simple TimeStampExtractor implementation it seems each consumer results in a separate watermark. Is there a prescribed way of handling such a thing that anyone has any experience with?
Thanks for your help, Andrew Griess
