alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7887 added additional JsonSerde constructor

Browse Source
This commit is contained in:
Mark Banierink 2024-05-21 21:49:01 +02:00 committed by Jiri Pechanec
parent 117725ab54
commit 4bc98c6661
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-core/src/main/java/io/debezium/serde/json/JsonSerde.java
View File

@ -42,7 +42,11 @@ public class JsonSerde<T> implements Serde<T> {
private JsonSerdeConfig config;
public JsonSerde(Class<T> objectType) {
mapper = new ObjectMapper();
this(objectType, new ObjectMapper());
}
public JsonSerde(Class<T> objectType, ObjectMapper mapper) {
this.mapper = mapper;
mapper.registerModule(new JavaTimeModule());
this.reader = mapper.readerFor(objectType);