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 7008fd4 commit 66f9750Copy full SHA for 66f9750
benchmarks/load_example.py
@@ -1,4 +1,5 @@
1
#!/usr/bin/env python
2
+from __future__ import print_function
3
import threading, logging, time
4
5
from kafka import KafkaConsumer, KafkaProducer
@@ -53,9 +54,9 @@ def main():
53
54
time.sleep(10)
55
producer_stop.set()
56
consumer_stop.set()
- print 'Messages sent: %d' % threads[0].sent
57
- print 'Messages recvd: %d' % threads[1].valid
58
- print 'Messages invalid: %d' % threads[1].invalid
+ print('Messages sent: %d' % threads[0].sent)
+ print('Messages recvd: %d' % threads[1].valid)
59
+ print('Messages invalid: %d' % threads[1].invalid)
60
61
if __name__ == "__main__":
62
logging.basicConfig(
0 commit comments