Merge pull request #12 from aiven/adding_timestamp

Adding timestamp

Author: ftisiot

pizzaproducer.py

@@ -1,4 +1,5 @@
 import random
+import time
 from faker.providers import BaseProvider
 
 # Adding a PizzaProvider with 3 methods:
@@ -69,7 +70,8 @@ def produce_msg (self, FakerInstance, ordercount = 1, max_pizzas_in_order = 5, m
  'name': FakerInstance.unique.name(),
  'phoneNumber': FakerInstance.unique.phone_number(),
  'address': FakerInstance.address(),
- 'pizzas': pizzas
+ 'pizzas': pizzas,
+ 'timestamp': int(time.time()*1000)
  }
  key = {'shop': shop}
  return message, key

userbets.py

@@ -1,4 +1,5 @@
 import random
+import time
 from faker.providers import BaseProvider
 
 MIN_AMOUNT = 2 # Min betting amount
@@ -58,7 +59,8 @@ def produce_msg (self):
  'subcategory': bet_event['subcategory'],
  'name': bet_event['event']
  },
- 'amount': bet_amount
+ 'amount': bet_amount,
+ 'timestap': int(time.time()*1000)
  }
  key = {'event': bet_event['event']}
  return message, key