Hello, I have questions on watermark generation and trigger about ReadFromKafka (Python SDK).
1.It only supports the following simple timestamp policies: - ProcessingTime - CreateTime - LogAppendTime Is there any way to assign event time from timestamp in a Kafka message? > The Java SDK supports it via CustomTimestampPolicyWithLimitedDelay > Pub/Sub I/O supports via timestamp_attribute 2. Let's say event time is assigned from CreateTime in the first place. Then timestamps are added to a PCollection's elements from those in Kafka messages. Then the AfterWatermark trigger is based on the original event time or new timestamp? Cheers, Jaehyeon
