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 8a7b837 commit 50efa73Copy full SHA for 50efa73
README.md
@@ -35,7 +35,7 @@ from confluent_kafka import Consumer
35
c = Consumer({'bootstrap.servers': 'mybroker', 'group.id': 'mygroup',
36
'default.topic.config': {'auto.offset.reset': 'smallest'}})
37
c.subscribe(['mytopic'])
38
-while running:
+while True:
39
msg = c.poll()
40
if not msg.error():
41
print('Received message: %s' % msg.value().decode('utf-8'))
0 commit comments