Skip to content

Commit 2f02129

Browse files
didiezrozza
authored andcommitted
Wrap nullable value returned from WriteModelStrategy using Optional.ofNullable(value)
KAFKA-227
1 parent 86b18d7 commit 2f02129

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/mongodb/kafka/connect/sink/MongoProcessedSinkRecordData.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,8 @@ private WriteModel<BsonDocument> buildWriteModel() {
8888
.getPostProcessors()
8989
.getPostProcessorList()
9090
.forEach(pp -> pp.process(sinkDocument, sinkRecord));
91-
return Optional.of(WriteModelStrategyHelper.createWriteModel(config, sinkDocument));
91+
return Optional.ofNullable(
92+
WriteModelStrategyHelper.createWriteModel(config, sinkDocument));
9293
})
9394
.orElse(null);
9495
}

0 commit comments

Comments
 (0)