diff --git a/v2/transmitter.py b/v2/transmitter.py index 7326eb7..c2d603a 100644 --- a/v2/transmitter.py +++ b/v2/transmitter.py @@ -140,6 +140,7 @@ class Transmitter: self.__send(self.db_name, tb, [json.dumps(item) for item in data]) except Exception as e: self.log.error(traceback.format_exc()) + self.log.error(data) buffer.clear() try: kafka_client.commit()