diff options
Diffstat (limited to 'benchmarks/load_example.py')
| -rwxr-xr-x | benchmarks/load_example.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/benchmarks/load_example.py b/benchmarks/load_example.py index a3b09ba..eef113e 100755 --- a/benchmarks/load_example.py +++ b/benchmarks/load_example.py @@ -1,4 +1,5 @@ #!/usr/bin/env python +from __future__ import print_function import threading, logging, time from kafka import KafkaConsumer, KafkaProducer @@ -53,9 +54,9 @@ def main(): time.sleep(10) producer_stop.set() consumer_stop.set() - print 'Messages sent: %d' % threads[0].sent - print 'Messages recvd: %d' % threads[1].valid - print 'Messages invalid: %d' % threads[1].invalid + print('Messages sent: %d' % threads[0].sent) + print('Messages recvd: %d' % threads[1].valid) + print('Messages invalid: %d' % threads[1].invalid) if __name__ == "__main__": logging.basicConfig( |