Skip to content

Commit 163d3f5

Browse files
hrchuedenhill
authored andcommitted
Update document
1 parent 18f7743 commit 163d3f5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

confluent_kafka/src/Consumer.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1236,7 +1236,8 @@ static PyMethodDef Consumer_methods[] = {
12361236
" :param bool cached: Instead of querying the broker used cached information. "
12371237
"Cached values: The low offset is updated periodically (if statistics.interval.ms is set) while "
12381238
"the high offset is updated on each message fetched from the broker for this partition.\n"
1239-
" :returns: Tuple of (low,high) on success or None on timeout.\n"
1239+
" :returns: Tuple of (low,high) on success or None on timeout. "
1240+
"The high offset is the offset of the last message + 1.\n"
12401241
" :rtype: tuple(int,int)\n"
12411242
" :raises: KafkaException\n"
12421243
" :raises: RuntimeError if called on a closed consumer\n"

0 commit comments

Comments
 (0)