diff --git a/target_postgres/postgres.py b/target_postgres/postgres.py
index 223c0d5..b8c98f7 100644
--- a/target_postgres/postgres.py
+++ b/target_postgres/postgres.py
@@ -313,7 +313,7 @@ def write_batch(self, stream_buffer):
                 return written_batches_details
             except Exception as ex:
                 cur.execute('ROLLBACK;')
-                message = 'Exception writing records'
+                message = f'Exception writing records for stream {stream_buffer.stream}'
                 self.LOGGER.exception(message)
                 raise PostgresError(message, ex)