kafka-connector syntax bug fix

ashutoshdtu · Mar 7, 2019 · 735ba20 · 735ba20
1 parent 9366b47
commit 735ba20
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/eazyserver/core/kafka_connector.py b/src/eazyserver/core/kafka_connector.py
@@ -58,7 +58,7 @@ def formatOutput(output,behavior,source_data):
 					break
 
 	if "_created" not in output: 		
-		logger.info("{} | source_id  {} not found for id {}".format(output["_producer"],output["source_id"],output["_id"])
+		logger.info("{} | source_id  {} not found for id {}".format(output["_producer"],output["source_id"],output["_id"]))
 		output["_created"] = output["_updated"]
 
 	return output