Relative Content

Tag Archive for apache-kafkaapache-flinkflink-sql

Flink Kafka Connector Fails to Reset Offset When No Data Exists at Specified Timestamp

I’m encountering an issue while using Apache Flink’s Kafka connector. My requirement is to consume data from a Kafka topic starting at a specific timestamp. However, I’m unsure whether there is data available at that timestamp in the topic. If no data exists, the connector throws an error. I would like the connector to reset the offset to the earliest available offset instead of failing when no data is found at the specified timestamp.