Fix not null event build
@@ -91,9 +91,10 @@ public class ErrorHandlerUtils {
for (Object item : streamEvent.getOutputData()) {
if (item == null) {
record.add(JsonNull.INSTANCE);
- }
+ } else {
record.add(String.valueOf(item));
}
+ }
records.add(record);
}
payloadJson.add("records", records);
@@ -126,9 +127,10 @@ public class ErrorHandlerUtils {
for (Object item : streamEvent.getOutputData()) {
if (item == null) {
record.add(JsonNull.INSTANCE);
- }
+ } else {
record.add(String.valueOf(item));
}
+ }
records.add(record);
}
}
