diff --git a/kafka/consumer.py b/kafka/consumer.py index e589c23..483a5ec 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -25,3 +25,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value) diff --git a/rabbit/consumer.py b/rabbit/consumer.py index fb0c61a..e414fab 100644 --- a/rabbit/consumer.py +++ b/rabbit/consumer.py @@ -31,3 +31,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value) diff --git a/zmq/consumer.py b/zmq/consumer.py index 6a18d68..fe584e2 100644 --- a/zmq/consumer.py +++ b/zmq/consumer.py @@ -25,3 +25,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value)