diff --git a/config/log4j.properties b/config/log4j.properties
index db227d237a25..07a11c170b72 100644
--- a/config/log4j.properties
+++ b/config/log4j.properties
@@ -30,3 +30,6 @@ log4j.logger.org.apache.zookeeper=ERROR, stdout
 log4j.logger.org.apache.kafka=ERROR, stdout
 log4j.logger.org.I0Itec.zkclient=ERROR, stdout
 log4j.logger.org.reflections=ERROR, stdout
+
+# Uncomment the following line to stop KSQL from logging out each request it receives:
+#log4j.logger.io.confluent.ksql.rest.server.resources.KsqlResource=WARN, stdout
diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java
index bd02a58e5719..780d44e24de2 100644
--- a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java
+++ b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/resources/KsqlResource.java
@@ -67,6 +67,8 @@
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
 import org.apache.kafka.streams.StreamsConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 // CHECKSTYLE_RULES.OFF: ClassDataAbstractionCoupling
 @Path("/ksql")
@@ -75,6 +77,8 @@
 public class KsqlResource implements KsqlConfigurable {
   // CHECKSTYLE_RULES.ON: ClassDataAbstractionCoupling
 
+  private static final Logger LOG = LoggerFactory.getLogger(KsqlResource.class);
+
   private static final List<ParsedStatement> TERMINATE_CLUSTER =
       new DefaultKsqlParser().parse(TerminateCluster.TERMINATE_CLUSTER_STATEMENT_TEXT);
 
@@ -171,6 +175,8 @@ public Response terminateCluster(
       @Context final ServiceContext serviceContext,
       final ClusterTerminateRequest request
   ) {
+    LOG.info("Received: " + request);
+
     throwIfNotConfigured();
 
     ensureValidPatterns(request.getDeleteTopicList());
@@ -189,6 +195,8 @@ public Response handleKsqlStatements(
       @Context final ServiceContext serviceContext,
       final KsqlRequest request
   ) {
+    LOG.info("Received: " + request);
+
     throwIfNotConfigured();
 
     activenessRegistrar.updateLastRequestTime();
diff --git a/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/ClusterTerminateRequest.java b/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/ClusterTerminateRequest.java
index 3ba5c412f9c0..e27a4e62356a 100644
--- a/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/ClusterTerminateRequest.java
+++ b/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/ClusterTerminateRequest.java
@@ -67,4 +67,11 @@ public boolean equals(final Object o) {
     final ClusterTerminateRequest that = (ClusterTerminateRequest) o;
     return Objects.equals(deleteTopicList, that.deleteTopicList);
   }
+
+  @Override
+  public String toString() {
+    return "ClusterTerminateRequest{"
+        + "deleteTopicList=" + deleteTopicList
+        + '}';
+  }
 }
diff --git a/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/KsqlRequest.java b/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/KsqlRequest.java
index 5ac44bf5fce6..a1c1fe261a9d 100644
--- a/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/KsqlRequest.java
+++ b/ksql-rest-model/src/main/java/io/confluent/ksql/rest/entity/KsqlRequest.java
@@ -85,6 +85,15 @@ public int hashCode() {
     return Objects.hash(ksql, streamsProperties, commandSequenceNumber);
   }
 
+  @Override
+  public String toString() {
+    return "KsqlRequest{"
+        + "ksql='" + ksql + '\''
+        + ", streamsProperties=" + streamsProperties
+        + ", commandSequenceNumber=" + commandSequenceNumber
+        + '}';
+  }
+
   /**
    * Converts all Class references values to their canonical String value.
    * </p>