fix MyRebalancer on docs/consumer.rst (#731)

* fix MyRebalancer on docs/consumer.rst * Create 731.doc
aio-libs · Dec 30, 2021 · d3fa429 · d3fa429
1 parent 6b15132
commit d3fa429
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/CHANGES/731.doc b/CHANGES/731.doc
@@ -0,0 +1 @@
+fix MyRebalancer on docs/consumer.rst
diff --git a/docs/consumer.rst b/docs/consumer.rst
@@ -353,7 +353,7 @@ etc. See :meth:`aiokafka.AIOKafkaConsumer.subscribe` docs for more details.
         class MyRebalancer(aiokafka.ConsumerRebalanceListener):
 
             async def on_partitions_revoked(self, revoked):
-                async with self.lock:
+                async with lock:
                     pass
 
             async def on_partitions_assigned(self, assigned):
@@ -362,7 +362,7 @@ etc. See :meth:`aiokafka.AIOKafkaConsumer.subscribe` docs for more details.
         async def main():
             consumer.subscribe("topic", listener=MyRebalancer())
             while True:
-                async with self.lock:
+                async with lock:
                     msgs = await consumer.getmany(timeout_ms=1000)
                     # process messages