- Type Parameters:
T - The type of records handled by the watermark generator
KPH - The type of the Kafka partition descriptor, which varies across Kafka versions.
public final class KafkaTopicPartitionStateWithPeriodicWatermarks<T,KPH>
A special version of the per-kafka-partition-state that additionally holds
a periodic watermark generator (and timestamp extractor) per partition.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.