Skip to content

Commit

Permalink
fix: do not handle produce error
Browse files Browse the repository at this point in the history
  • Loading branch information
manjeet9727 committed Apr 28, 2024
1 parent 2f7b41c commit ebf5079
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions blockchainetl/jobs/exporters/kafka_exporter.py
Original file line number Diff line number Diff line change
Expand Up @@ -92,10 +92,7 @@ def already_processed(self, item_type, item_id):

# utility functions to produce message to kafka
def produce_message(self, item_type, data):
try:
return self.producer.send(item_type, value=data)
except Exception as e:
logging.error(f"Record marked as processed in Redis but unable to produce it to kafka - {item_type} - {data} - Exception=", e)
return self.producer.send(item_type, value=data)

# utility functions to convert numeric data to string format
def parse_data(self, item):
Expand Down

0 comments on commit ebf5079

Please sign in to comment.