ruby-kafka
ruby-kafka copied to clipboard
Support for KAFKA-4148 / KIP-79 / search offsets by timestamp in Consumer
I was trying to find method similar to offsetsForTimes in java or offsets_for_times in python. It was introduced to Kafka in KAFKA-4148.
It is useful in writing on-demand/cron jobs to consume & process messages within a time range.
Is there any plan to support this in ruby-kafka also?