Subject: [PATCH] enable ALLOW_LEADING_ZEROS_FOR_NUMBERS in jackson object mapper. --- Index: connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java --- a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java (revision 4a0b6ebf60ed7614f042443460b490971e8662a4) +++ b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java (date 1683123395423) @@ -38,6 +38,7 @@ */ public JsonSerializer() { this(Collections.emptySet(), JsonNodeFactory.withExactBigDecimals(true)); + objectMapper.enable(JsonReadFeature.ALLOW_LEADING_ZEROS_FOR_NUMBERS.mappedFeature()); } /** Index: connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java --- a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java (revision 4a0b6ebf60ed7614f042443460b490971e8662a4) +++ b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java (date 1683123721312) @@ -51,6 +51,7 @@ final JsonNodeFactory jsonNodeFactory ) { deserializationFeatures.forEach(objectMapper::enable); + objectMapper.enable(JsonReadFeature.ALLOW_LEADING_ZEROS_FOR_NUMBERS.mappedFeature()); objectMapper.setNodeFactory(jsonNodeFactory); }