diff --git a/db.py b/db.py
index 7d265c5..f6b3774 100644
--- a/db.py
+++ b/db.py
@@ -112,7 +112,7 @@ async def store_kafka_batch(data):
         # )
     log.debug(
         "Kafka batches sent: "
-        + ", ".join([topic + ": " + str(len(topicmap[topic])) for topic in topicmap])
+        + ", ".join([tpc + ": " + str(len(topicmap[tpc])) for tpc in topicmap])
     )
     await producer.stop()