From c4dc70082a07787a23439fcb5d8c602d0b9d2f36 Mon Sep 17 00:00:00 2001 From: StrikeW Date: Thu, 2 Nov 2023 17:00:04 +0800 Subject: [PATCH] fix typo --- .../risingwave/connector/source/core/DbzCdcEventConsumer.java | 2 +- .../com/risingwave/connector/source/core/DbzJsonConverter.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEventConsumer.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEventConsumer.java index 713edc95f2a74..e45fdded17c71 100644 --- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEventConsumer.java +++ b/java/connector-node/risingwave-connector-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 configs = new HashMap<>(2); diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java index 3cd2c5c5fb081..11fcdcba55553 100644 --- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java +++ b/java/connector-node/risingwave-connector-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. * *