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.
2 parents 6a6ee3b + 46375fc commit cb0d0afCopy full SHA for cb0d0af
README.md
@@ -35,10 +35,13 @@ 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
+running = True
39
while running:
40
msg = c.poll()
41
if not msg.error():
42
print('Received message: %s' % msg.value().decode('utf-8'))
43
+ else:
44
+ running = False
45
c.close()
46
```
47
0 commit comments