Added exception message

Signed-off-by: Krishna Kondaka <[email protected]>
kkondaka · Aug 17, 2023 · 7f33cd3 · 7f33cd3
1 parent 4c9501e
commit 7f33cd3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaSourceCustomConsumer.java b/...ain/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);