Apache Flink as Stream Data Pipeline

To enable data re-processing at any given time (or partition and offset), we need the following:

Topic - The Kafka stream topic. Partition - The Kafka stream partition. Offset - The Kafka stream offset. Timestamp - The Kafka stream timestamp.