Skip to content

Commit 139c546

Browse files
authored
docs: remove incorrect await (#858)
`AIOKafkaConsumer.highwater` is not an async method.
1 parent a878f3f commit 139c546

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

docs/consumer.rst

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ bulk. The algorithm can be enhanced by taking advantage of:
144144

145145
* :meth:`await consumer.getmany() <aiokafka.AIOKafkaConsumer.getmany>` to
146146
avoid multiple calls to get a batch of messages.
147-
* :meth:`await consumer.highwater(partition)
147+
* :meth:`consumer.highwater(partition)
148148
<aiokafka.AIOKafkaConsumer.highwater>` to understand if we have more
149149
unconsumed messages or this one is the last one in the partition.
150150

0 commit comments

Comments
 (0)