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.