rm print data in kafka exporter

blockchain-etl · Sep 22, 2022 · d34b28e · d34b28e
1 parent e1f658b
commit d34b28e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/blockchainetl/jobs/exporters/kafka_exporter.py b/blockchainetl/jobs/exporters/kafka_exporter.py
@@ -33,7 +33,7 @@ def export_item(self, item):
         item_type = item.get('type')
         if item_type is not None and item_type in self.item_type_to_topic_mapping:
             data = json.dumps(item).encode('utf-8')
-            print(data)
+            logging.debug(data)
             return self.producer.send(self.item_type_to_topic_mapping[item_type], value=data)
         else:
             logging.warning('Topic for item type "{}" is not configured.'.format(item_type))