Skip to content

Commit fd30c01

Browse files
committed
Test regression fix, handle Integers and Longs
1 parent 6566231 commit fd30c01

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/integrationTest/java/com/mongodb/kafka/connect/sink/MongoSinkTaskIntegrationTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ void testSinkCanHandleInvalidCDCWhenErrorToleranceIsAll() {
288288
Document::toJson,
289289
d ->
290290
d.get("_id", 0) != 4 ? format("{op: 'c', after: '%s'}", d.toJson()) : "{op: 'c'}",
291-
d -> d.get("_id", 0L));
291+
d -> d.get("_id", 0));
292292

293293
task.put(sinkRecords);
294294

@@ -361,7 +361,7 @@ private Map<String, String> createSettings() {
361361

362362
static List<SinkRecord> createRecords(final List<Document> documents) {
363363
return createRecords(
364-
documents.stream(), Document::toJson, Document::toJson, d -> d.get("_id", 0L));
364+
documents.stream(), Document::toJson, Document::toJson, d -> d.get("_id", 0));
365365
}
366366

367367
static <I> List<SinkRecord> createRecords(

0 commit comments

Comments
 (0)