fix typo

risingwavelabs · Nov 2, 2023 · c4dc700 · c4dc700
1 parent 7f6cac5
commit c4dc700
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEventConsumer.java b/...ector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEventConsumer.java
@@ -51,7 +51,7 @@ public class DbzCdcEventConsumer
         this.heartbeatTopicPrefix = heartbeatTopicPrefix;
 
         // The default JSON converter will output the schema field in the JSON which is unnecessary
-        // to source parser, we use a customized JSON converter to avoid outputing the `schema`
+        // to source parser, we use a customized JSON converter to avoid outputting the `schema`
         // field.
         var jsonConverter = new DbzJsonConverter();
         final HashMap<String, Object> configs = new HashMap<>(2);

diff --git a/...onnector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java b/...onnector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java
@@ -19,7 +19,7 @@
 import org.apache.kafka.connect.json.JsonConverter;
 
 /**
- * Customize the JSON converter to avoid outputing the `schema` field but retian `payload` field in
+ * Customize the JSON converter to avoid outputting the `schema` field but retian `payload` field in
  * the JSON output. e.g.
  *
  * <pre>