Log and error message cleanups 2/2

Author: rozza

src/main/java/com/mongodb/kafka/connect/sink/writemodel/strategy/DeleteOneDefaultStrategy.java

@@ -51,7 +51,7 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
         .orElseThrow(
             () ->
                 new DataException(
-                    "Cannot build the WriteModel since the key document was missing unexpectedly"));
+                    "Could not build the WriteModel,the key document was missing unexpectedly"));
 
     // NOTE: current design doesn't allow to access original SinkRecord (= null)
     BsonDocument deleteFilter;

src/main/java/com/mongodb/kafka/connect/sink/writemodel/strategy/ReplaceOneBusinessKeyStrategy.java

@@ -43,15 +43,15 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
             .orElseThrow(
                 () ->
                     new DataException(
-                        "Cannot build the WriteModel since the value document was missing unexpectedly"));
+                        "Could not build the WriteModel,the value document was missing unexpectedly"));
 
     try {
       BsonDocument businessKey = vd.getDocument(ID_FIELD);
       vd.remove(ID_FIELD);
       return new ReplaceOneModel<>(businessKey, vd, REPLACE_OPTIONS);
     } catch (BSONException e) {
       throw new DataException(
-          "Cannot build the WriteModel since the value document does not contain an _id field of"
+          "Could not build the WriteModel,the value document does not contain an _id field of"
               + " type BsonDocument which holds the business key fields.\n\n If you are including an"
               + " existing `_id` value in the business key then ensure `document.id.strategy.overwrite.existing=true`.");
     }

src/main/java/com/mongodb/kafka/connect/sink/writemodel/strategy/ReplaceOneDefaultStrategy.java

@@ -42,7 +42,7 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
             .orElseThrow(
                 () ->
                     new DataException(
-                        "Cannot build the WriteModel since the value document was missing unexpectedly"));
+                        "Could not build the WriteModel,the value document was missing unexpectedly"));
 
     return new ReplaceOneModel<>(new BsonDocument(ID_FIELD, vd.get(ID_FIELD)), vd, REPLACE_OPTIONS);
   }

src/main/java/com/mongodb/kafka/connect/sink/writemodel/strategy/UpdateOneBusinessKeyTimestampStrategy.java

@@ -46,7 +46,7 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
             .orElseThrow(
                 () ->
                     new DataException(
-                        "Cannot build the WriteModel since the value document was missing unexpectedly"));
+                        "Could not build the WriteModel,the value document was missing unexpectedly"));
 
     BsonDateTime dateTime = new BsonDateTime(Instant.now().toEpochMilli());
 
@@ -62,7 +62,7 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
 
     } catch (BSONException e) {
       throw new DataException(
-          "Cannot build the WriteModel since the value document does not contain an _id field of"
+          "Could not build the WriteModel,the value document does not contain an _id field of"
               + " type BsonDocument which holds the business key fields.\n\n If you are including an"
               + "existing `_id` value in the business key then ensure `document.id.strategy.overwrite.existing=true`.");
     }

src/main/java/com/mongodb/kafka/connect/sink/writemodel/strategy/UpdateOneTimestampsStrategy.java

@@ -46,7 +46,7 @@ public WriteModel<BsonDocument> createWriteModel(final SinkDocument document) {
             .orElseThrow(
                 () ->
                     new DataException(
-                        "Cannot build the WriteModel since the value document was missing unexpectedly"));
+                        "Could not build the WriteModel,the value document was missing unexpectedly"));
 
     BsonDateTime dateTime = new BsonDateTime(Instant.now().toEpochMilli());
 

src/main/java/com/mongodb/kafka/connect/source/MongoSourceTask.java

@@ -219,7 +219,7 @@ public List<SourceRecord> poll() {
 
         if (topicName.isEmpty()) {
           LOGGER.warn(
-              "No topic set. Cannot publish the message: {}", changeStreamDocument.toJson());
+              "No topic set. Could not publish the message: {}", changeStreamDocument.toJson());
           return sourceRecords;
         }