|
I want to apply Mongo connect as cronjob, so I change poll.await.time.ms to high number (60000 - 1 minutes or 1 day).
But as soon as I update document, the message produced immediately.
{ "name": "pp",
|
"config": {
|
"behavior.on.null.values": "ignore", "connection.timeout.ms": "60000",
|
"max.retries": "2147483647",
|
"read.timeout.ms": "300000", "max.connection.idle.time.ms": "3000000", "behavior.on.malformed.documents": "warn", "key.converter.schemas.enable": "false", "value.converter.schemas.enable": "false",
|
"name": "pp",
|
"connector.class": "com.mongodb.kafka.connect.MongoSourceConnector", "tasks.max": "1",
|
"key.converter": "Json",
|
"value.converter": "Json",
|
"errors.retry.timeout": "-1",
|
"errors.tolerance": "none",
|
"connection.uri": "mongodb://...",
|
"database": "...",
|
"collection": "...",
|
"pipeline": "[ { \"$match\":{ \"operationType\":{ \"$in\":[ \"insert\", \"update\", \"delete\", \"replace\" ] } } } ]", "publish.full.document.only": "false", "change.stream.full.document": "updateLookup", "poll.await.time.ms": "600000",
|
"startup.mode": "copy_existing",
|
"mongo.errors.tolerance": "none",
|
"offset.partition.name": "pp.0" }}
|
|