diff --git a/src/pgsql/pgsql.lisp b/src/pgsql/pgsql.lisp
index 3684017..781b6ba 100644
--- a/src/pgsql/pgsql.lisp
+++ b/src/pgsql/pgsql.lisp
@@ -20,7 +20,9 @@
           (unwind-protect
                (loop for i below batch-rows
                   for copy-string = (aref batch i)
-                  do (log-message :data "> ~s" copy-string)
+                  do (when (or (eq :data *log-min-messages*)
+                               (eq :data *client-min-messages*))
+                       (log-message :data "> ~s" copy-string))
                   do (cl-postgres:db-write-row copier nil copy-string)
                   finally (return batch-rows))
             (cl-postgres:close-db-writer copier))))
diff --git a/src/queue.lisp b/src/queue.lisp
index 55925c8..deb4be1 100644
--- a/src/queue.lisp
+++ b/src/queue.lisp
@@ -33,7 +33,9 @@
 (defun batch-row (row copy queue)
   "Add ROW to the reader batch. When the batch is full, provide it to the
    writer as the *writer-batch*."
-  (log-message :data "< ~s" row)
+  (when (or (eq :data *log-min-messages*)
+            (eq :data *client-min-messages*))
+    (log-message :data "< ~s" row))
   (let ((oversized? (oversized? *current-batch*)))
     (when (or (= (batch-count *current-batch*) *copy-batch-rows*)
               oversized?)
diff --git a/src/utils.lisp b/src/utils.lisp
index 878b4f4..4f21d4f 100644
--- a/src/utils.lisp
+++ b/src/utils.lisp
@@ -332,6 +332,8 @@
 			    (*myconn-port*        . ,*myconn-port*)
 			    (*myconn-user*        . ,*myconn-user*)
 			    (*myconn-pass*        . ,*myconn-pass*)
-			    (*state*              . ,*state*))))
+			    (*state*              . ,*state*)
+                            (*client-min-messages* . ,*client-min-messages*)
+                            (*log-min-messages*    . ,*log-min-messages*))))
   "Wrapper around lparallel:make-kernel that sets our usual bindings."
   (lp:make-kernel worker-count :bindings bindings))