diff --git a/aiokafka/consumer/consumer.py b/aiokafka/consumer/consumer.py index cc509f50..559fa35a 100644 --- a/aiokafka/consumer/consumer.py +++ b/aiokafka/consumer/consumer.py @@ -927,7 +927,8 @@ async def offsets_for_times(self, timestamps): Returns: dict(TopicPartition, OffsetAndTimestamp): mapping from partition to the timestamp and offset of the first message with - timestamp greater than or equal to the target timestamp. + timestamp greater than or equal to the target timestamp. None will + be returned for the partition if there is no such message. Raises: ValueError: If the target timestamp is negative