How to check is Kafka partition "idle" in emitRecordsWithTimestamps

Posted by Alexey Trenikhun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-to-check-is-Kafka-partition-idle-in-emitRecordsWithTimestamps-tp44048.html

Hello,

I'm thinking about implementing custom Kafka connector which provides event alignment (similar to FLINK-10921, which seems abandoned). What is the way to determine is partition is idle from override of AbstractFetcher.emitRecordsWithTimestamps()? Does KafkaTopicPartitionState has this information ?

Thanks,

Alexey