Details
-
Question
-
Resolution: Works as Designed
-
Unknown
-
None
-
1.9.1
-
None
Description
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" }} |
Attachments
Issue Links
- related to
-
KAFKA-356 Update poll.await.time.ms documentation
-
- Closed
-