yet more formatting

airbytehq · Jun 26, 2024 · f3bb580 · f3bb580
1 parent a27284e
commit f3bb580
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/.../kotlin/io/airbyte/cdk/integrations/destination/async/deser/AirbyteMessageDeserializer.kt b/.../kotlin/io/airbyte/cdk/integrations/destination/async/deser/AirbyteMessageDeserializer.kt
@@ -26,8 +26,8 @@ class AirbyteMessageDeserializer(
      * Message.
      *
      * Throws on deserialization errors, obfuscating the error message to avoid data leakage. In
-     * recoverable cases (currently only when the top-level message type is unrecognized), throws
-     * a dedicated exception.
+     * recoverable cases (currently only when the top-level message type is unrecognized), throws a
+     * dedicated exception.
      *
      * PartialAirbyteMessage holds either:
      * * entire serialized message string when message is a valid State Message

diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/json/Jsons.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/json/Jsons.kt
@@ -139,6 +139,9 @@ object Jsons {
         }
     }
 
+    // WARNING: This message throws bare exceptions on parse failure which might
+    // leak sensitive data. Use obfuscateDeserializationException() to strip
+    // the sensitive data before logging.
     @JvmStatic
     fun <T : Any> deserializeExactUnchecked(jsonString: String?, klass: Class<T>?): T {
         return OBJECT_MAPPER_EXACT.readValue(jsonString, klass)