Is there a way for Flink watermarks to advance per record when reading from Kafka instead of at a fixed period? I was under the assumption of SET 'pipeline.auto-watermark-interval' = '0ms'; would do it, but instead it just generated NULL watermarks for everything. Seems like it is related to this issue here: https://issues.apache.org/jira/browse/FLINK-21931.