diff --git a/cratedb_toolkit/io/kinesis/relay.py b/cratedb_toolkit/io/kinesis/relay.py
index 274eb7f3..574bcba5 100644
--- a/cratedb_toolkit/io/kinesis/relay.py
+++ b/cratedb_toolkit/io/kinesis/relay.py
@@ -84,7 +84,7 @@ def process_event(self, event):
 
             self.connection.commit()
         except sa.exc.ProgrammingError as ex:
-            logger.warning(f"Running query failed: {ex}")
+            logger.exception(f"Executing query failed: {ex}")
         self.progress_bar.update()
 
     def __del__(self):