@ -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()