public static class TimestampPolicyFactory.LogAppendTimePolicy<K,V>
Assigns Kafka's log append time (server side ingestion time) to each record. The watermark for
each Kafka partition is the timestamp of the last record read. If a partition is idle, the
watermark advances roughly to 'current time - 2 seconds'. See KafkaIO.Read.withLogAppendTime() for longer description.
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.beam.sdk.io.kafka.TimestampPolicy
Returns watermark for the partition. It is the timestamp before or at the timestamps of all
future records consumed from the partition. See UnboundedSource.UnboundedReader#getWatermark() for more guidance on watermarks. E.g. if the
record timestamp is 'LogAppendTime', watermark would be the timestamp of the last record since
'LogAppendTime' monotonically increases within a partition.