Clean up docker environment

db.py

@@ -44,6 +44,8 @@ KEYNAME = "queue"
 
 
 async def store_kafka_batch(data):
+    print("FAKE STORE KAFKA BATCH")
+    return
     # log.debug(f"Storing Kafka batch of {len(data)} messages")
     producer = AIOKafkaProducer(bootstrap_servers="kafka:9092")
     await producer.start()