Merge pull request #123 from embano1/issue-122

fix: remove putIfAbsent calls
awslabs · Sep 7, 2023 · d46309d · d46309d
2 parents b8c261a + b511b65
commit d46309d
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java b/src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java
@@ -73,22 +73,22 @@ private String createJsonPayload(SinkRecord record) throws IOException {
     root.put("offset", record.kafkaOffset());
     root.put("timestamp", record.timestamp());
     root.put("timestampType", record.timestampType().toString());
-    root.putIfAbsent("headers", createHeaderArray(record));
+    root.set("headers", createHeaderArray(record));
 
     if (record.key() == null) {
-      root.putIfAbsent("key", null);
+      root.set("key", null);
     } else {
-      root.putIfAbsent(
+      root.set(
           "key",
           createJSONFromByteArray(
               jsonConverter.fromConnectData(record.topic(), record.keySchema(), record.key())));
     }
 
     // tombstone handling
     if (record.value() == null) {
-      root.putIfAbsent("value", null);
+      root.set("value", null);
     } else {
-      root.putIfAbsent(
+      root.set(
           "value",
           createJSONFromByteArray(
               jsonConverter.fromConnectData(record.topic(), record.valueSchema(), record.value())));
@@ -109,7 +109,7 @@ private ArrayNode createHeaderArray(SinkRecord record) throws IOException {
 
     for (Header header : record.headers()) {
       var headerItem = objectMapper.createObjectNode();
-      headerItem.putIfAbsent(
+      headerItem.set(
           header.key(),
           createJSONFromByteArray(
               jsonConverter.fromConnectHeader(