Hello!

I added a KIP to to add a method that would determine the offsets for a
list of topic partitions based on offset and update the consumer assignment
to seek to those offsets.

https://cwiki.apache.org/confluence/display/KAFKA/KIP-397%3A+Add+methods+to+override+fetch+offsets+based+on+timestamp

Let me know if you have any questions or feedback.

Thanks!
Brandon K.

Reply via email to