diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/service/SchemaService.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/service/SchemaService.java
index a5d7883d7a..88e209cbc2 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/service/SchemaService.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/service/SchemaService.java
@@ -135,7 +135,7 @@ public void registerSchema(final String topic) {
                 registerSchema(topic, schemaString);
             }
         } catch (Exception e) {
-            throw new RuntimeException("error occured while  schema registeration " + e.getMessage());
+            throw new RuntimeException("error occurred while  schema registeration " + e.getMessage());
         }
     }