kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gong, Yifei" <Yifei.G...@mlp.com>
Subject OffsetsForTimes returns null when it shouldn't
Date Tue, 15 Dec 2020 07:36:32 GMT
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.

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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message