diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java index 6a17ae277b..41014dcd20 100644 --- a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java +++ b/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java @@ -141,7 +141,7 @@ public class JsonConverter implements Converter, HeaderConverter { // names specified in the field private static final HashMap LOGICAL_CONVERTERS = new HashMap<>(); - private static final JsonNodeFactory JSON_NODE_FACTORY = JsonNodeFactory.withExactBigDecimals(true); + private static final JsonNodeFactory JSON_NODE_FACTORY = new JsonNodeFactory(true); static { LOGICAL_CONVERTERS.put(Decimal.LOGICAL_NAME, new LogicalTypeConverter() { 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 index 2e6e821b2d..2dd281a08d 100644 --- 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 @@ -36,7 +36,7 @@ public class JsonDeserializer implements Deserializer { * Default constructor needed by Kafka */ public JsonDeserializer() { - this(Collections.emptySet(), JsonNodeFactory.withExactBigDecimals(true)); + this(Collections.emptySet(), new JsonNodeFactory(true)); } /** 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 index 0f2b62bd0a..9591d5edb5 100644 --- 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 @@ -37,7 +37,7 @@ public class JsonSerializer implements Serializer { * Default constructor needed by Kafka */ public JsonSerializer() { - this(Collections.emptySet(), JsonNodeFactory.withExactBigDecimals(true)); + this(Collections.emptySet(), new JsonNodeFactory(true)); } /** diff --git a/connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java b/connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java index 4e4c53b9d9..37ed853f66 100644 --- a/connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java +++ b/connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java @@ -64,7 +64,7 @@ public class JsonConverterTest { private final ObjectMapper objectMapper = new ObjectMapper() .enable(DeserializationFeature.USE_BIG_DECIMAL_FOR_FLOATS) - .setNodeFactory(JsonNodeFactory.withExactBigDecimals(true)); + .setNodeFactory(new JsonNodeFactory(true)); private final JsonConverter converter = new JsonConverter(); diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle index 7a9286277b..3483d4e2bb 100644 --- a/gradle/dependencies.gradle +++ b/gradle/dependencies.gradle @@ -66,8 +66,8 @@ versions += [ grgit: "4.1.1", httpclient: "4.5.13", easymock: "4.3", - jackson: "2.13.4", - jacksonDatabind: "2.13.4.2", + jackson: "2.16.0", + jacksonDatabind: "2.16.0", jacoco: "0.8.7", javassist: "3.27.0-GA", jetty: "9.4.48.v20220622", @@ -128,7 +128,7 @@ versions += [ zookeeper: "3.6.3", zstd: "1.5.2-1", commonLang: "3.12.0", - s3stream: "0.5.5-SNAPSHOT", + s3stream: "0.5.6-SNAPSHOT", ] libs += [ activation: "javax.activation:activation:$versions.activation",