You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "Gong, Yifei" <Yi...@mlp.com> on 2020/12/15 07:36:32 UTC

OffsetsForTimes returns null when it shouldn't

Hi team,

I found that when I seek to a recent timestamp using OffsetsForTimes method:
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L2078
It returns me offsets for all partitions.
However, if I seek an earlier timestamp, it only returns me offsets for some of the partitions and nulls for the rest.
As per the documentation, null means "no such message found", but if I can get a message with a more recent timestamp, it means the message is indeed there right?
I've raised this in stack overflow here with an example:
https://stackoverflow.com/questions/65288469/spring-kafka-offsetsfortimes-method-returns-null-for-some-partitions
I am not sure what could be the cause of this? Can someone help?

Thanks,
Yifei


######################################################################

The information contained in this communication is confidential and

may contain information that is privileged or exempt from disclosure

under applicable law. If you are not a named addressee, please notify

the sender immediately and delete this email from your system.

If you have received this communication, and are not a named

recipient, you are hereby notified that any dissemination,

distribution or copying of this communication is strictly prohibited.

######################################################################