Skip to content

Commit 29b81c5

Browse files
committed
Improve consumer example to not exit when end of partition is reached
1 parent fac4543 commit 29b81c5

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

README.md

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ p.flush()
3030
**High-level Consumer:**
3131

3232
```python
33-
from confluent_kafka import Consumer
33+
from confluent_kafka import Consumer, KafkaError
3434

3535
c = Consumer({'bootstrap.servers': 'mybroker', 'group.id': 'mygroup',
3636
'default.topic.config': {'auto.offset.reset': 'smallest'}})
@@ -40,7 +40,8 @@ while running:
4040
msg = c.poll()
4141
if not msg.error():
4242
print('Received message: %s' % msg.value().decode('utf-8'))
43-
else:
43+
elif msg.error().code() != KafkaError._PARTITION_EOF:
44+
print(msg.error())
4445
running = False
4546
c.close()
4647
```

0 commit comments

Comments
 (0)