We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cb2006c commit 64adc84Copy full SHA for 64adc84
aiokafka/consumer/consumer.py
@@ -927,7 +927,8 @@ async def offsets_for_times(self, timestamps):
927
Returns:
928
dict(TopicPartition, OffsetAndTimestamp): mapping from
929
partition to the timestamp and offset of the first message with
930
- timestamp greater than or equal to the target timestamp.
+ timestamp greater than or equal to the target timestamp. None will
931
+ be returned for the partition if there is no such message.
932
933
Raises:
934
ValueError: If the target timestamp is negative
0 commit comments