diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaSourceCustomConsumer.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaSourceCustomConsumer.java
index 94432c77c7..96767016c5 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaSourceCustomConsumer.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaSourceCustomConsumer.java
@@ -165,7 +165,7 @@ public <T> void consumeRecords() throws Exception {
             LOG.warn("Deserialization error - topic {} partition {} offset {}",
                      e.topicPartition().topic(), e.topicPartition().partition(), e.offset());
             if (e.getCause() instanceof AWSSchemaRegistryException) {
-                LOG.warn("AWSSchemaRegistryException. Retrying after 30 seconds");
+                LOG.warn("AWSSchemaRegistryException: {}. Retrying after 30 seconds", e.getMessage());
                 Thread.sleep(30000);
             } else {
                 LOG.warn("Seeking past the error record", e);