Thanks for the proposal Becket. Looks good overall, a few comments: ListOffsetResponse => [TopicName [PartitionOffsets]] > PartitionOffsets => Partition ErrorCode Timestamp [Offset] > Partition => int32 > ErrorCode => int16 > Timestamp => int64 > Offset => int
It should be int64 for `Offset` right? Implementation wise, we will migrate to o.a.k.common.requests.ListOffsetRequest > class on the broker side. Could you clarify what you mean here? We already use o.a.k.common.requests.ListOffsetRequest in KafkaApis. long offset = consumer.offsetForTime(Collections.singletonMap(topicPartition, > targetTime)).offset; The result of `offsetForTime` is a Map, so we can't just call `offset` on it. You probably meant something like: long offset = consumer.offsetForTime(Collections.singletonMap(topicPartition, targetTime)).get(topicPartition).offset; Test searchByTimestamp with CreateTime and LogAppendTime > Do you mean `Test offsetForTime`? And: 1. In KAFKA-1588, the following issue was described "When performing an OffsetRequest, if you request the same topic and partition combination in a single request more than once (for example, if you want to get both the head and tail offsets for a partition in the same request), you will get a response for both, but they will be the same offset". Will the new request version support the use case where multiple timestamps are passed for the same topic partition? And if we do support it at the protocol level, do we also want to support it at the API level or do we think the additional complexity is not worth it? 2. Is `offsetForTime` the right method name given that we are getting multiple offsets? Maybe it should be `offsetsForTimes` or something like that. Ismael On Wed, Aug 31, 2016 at 4:38 AM, Becket Qin <becket....@gmail.com> wrote: > Hi Kafka devs, > > I created KIP-79 to allow consumer to precisely query the offsets based on > timestamp. > > In short we propose to : > 1. add a ListOffsetRequest/ListOffsetResponse v1, and > 2. add an offsetForTime() method in new consumer. > > The KIP wiki is the following: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65868090 > > Comments are welcome. > > Thanks, > > Jiangjie (Becket) Qin >
