diff --git a/pom.xml b/pom.xml index 4323ce1..6392581 100644 --- a/pom.xml +++ b/pom.xml @@ -22,7 +22,7 @@ kafka-connect-transform-record2jsonstring kafka-connect-transform-record2jsonstring - 1.0 + 1.3 Kafka Connect single message transform (SMT) taking a record (with schema) and transforms it into a single JSON String https://github.com/an0r0c/kafka-connect-transform-tojsonstring @@ -132,7 +132,7 @@ com.github.javadev underscore - 1.82 + 1.81 org.mongodb diff --git a/src/test/java/com/github/cedelsb/kafka/connect/smt/Record2JsonStringConverterTest.java b/src/test/java/com/github/cedelsb/kafka/connect/smt/Record2JsonStringConverterTest.java index ff898a7..d66f22d 100644 --- a/src/test/java/com/github/cedelsb/kafka/connect/smt/Record2JsonStringConverterTest.java +++ b/src/test/java/com/github/cedelsb/kafka/connect/smt/Record2JsonStringConverterTest.java @@ -17,6 +17,7 @@ package com.github.cedelsb.kafka.connect.smt; import org.apache.kafka.connect.data.*; +import org.apache.kafka.connect.data.Date; import org.apache.kafka.connect.sink.SinkRecord; import org.junit.Before; import org.junit.Test; @@ -26,10 +27,7 @@ import java.time.LocalTime; import java.time.ZoneOffset; import java.time.ZonedDateTime; -import java.util.Arrays; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import static org.junit.Assert.assertEquals; import static org.junit.Assert.fail; @@ -247,6 +245,8 @@ public void transformRecordValue2JsonStringLogicalTypesDatetimeAsStringWithPatte props.put("json.writer.datetime.pattern", "dd.MM.yyyy HH:mm z"); props.put("json.writer.datetime.zoneid", "CET"); + Locale.setDefault(new Locale("en", "GB")); // Force Locale to be English so that the timezone display name is properly returned + valueSmt.configure(props); final SinkRecord record = new SinkRecord(null, 0, null, "test", simpleStructSchema, simpleStruct, 0);