From d34b28e4bf53445cffdbfe84eb395f3e5cb0a268 Mon Sep 17 00:00:00 2001 From: Max Cruz Date: Thu, 22 Sep 2022 10:39:23 -0400 Subject: [PATCH] rm print data in kafka exporter --- blockchainetl/jobs/exporters/kafka_exporter.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blockchainetl/jobs/exporters/kafka_exporter.py b/blockchainetl/jobs/exporters/kafka_exporter.py index ac75e242b..ea548d5b3 100644 --- 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))