Re: How to understand create watermark for Kafka partitions

2019-12-13 Thread vino yang
Hi Alex, >> But why also say created watermark for each Kafka topic partitions ? IMO, the official documentation has explained the reason. Just copied here: When using Apache Kafka as a data source, each Kafka

How to understand create watermark for Kafka partitions

2019-12-12 Thread qq
Hi all, I confused with watermark for each Kafka partitions. As I know watermark created by data stream level. But why also say created watermark for each Kafka topic partitions ? As I tested, watermarks also created by global, even I run my job with parallels. And assign watermarks on