From 7f33cd30be2aaa408fbccb21ff26c722b4bed631 Mon Sep 17 00:00:00 2001
From: Krishna Kondaka
 <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
Date: Thu, 17 Aug 2023 20:59:11 +0000
Subject: [PATCH] Added exception message

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
---
 .../plugins/kafka/consumer/KafkaSourceCustomConsumer.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);