You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
On the Source connector documentation, there is a typo, where the configuration is written without camel case.
If this parameter is used without camel case, the connector will not work properly.
| connection.uri | The connection URI as supported by the official drivers. eg: ``mongodb://user@pass@locahost/``. | string | mongodb://localhost:27017,localhost:27018,localhost:27019 | A valid connection string | high |
@@ -66,7 +67,7 @@ The following document represents all possible fields that a change stream respo
66
67
| pipeline | An inline JSON array with objects describing the pipeline operations to run. Example: `[{"$match": {"operationType": "insert"}}, {"$addFields": {"Kafka": "Rules!"}}]`| string |[]| A valid JSON array | medium |
67
68
| collation | The json representation of the Collation options to use for the change stream. Use the `Collation.asDocument().toJson()` to create the specific json representation. | string | "" | A valid JSON document representing a collation | high |
68
69
| batch.size | The cursor batch size. | int | 0 |[0,...]| medium |
69
-
| change.stream.full.document | Determines what to return for update operations when using a Change Stream. When set to 'updateLookup', the change stream for partial updates will include both a delta describing the changes to the document as well as a copy of the entire document that was changed from *some time* after the change occurred. | string | "" | An empty string OR [default, updatelookup]| high |
70
+
| change.stream.full.document | Determines what to return for update operations when using a Change Stream. When set to 'updateLookup', the change stream for partial updates will include both a delta describing the changes to the document as well as a copy of the entire document that was changed from *some time* after the change occurred. | string | "" | An empty string OR [default, updateLookup]| high |
70
71
| poll.await.time.ms | The amount of time to wait before checking for new results on the change stream | long | 5000 |[1,...]| low |
71
72
| poll.max.batch.size | Maximum number of change stream documents to include in a single batch when polling for new data. This setting can be used to limit the amount of data buffered internally in the connector. | int | 1000 |[1,...]| low |
72
73
| topic.prefix | Prefix to prepend to database & collection names to generate the name of the Kafka topic to publish data to. | string | "" || low |
@@ -75,6 +76,7 @@ The following document represents all possible fields that a change stream respo
75
76
| copy.existing.queue.size | The max size of the queue to use when copying data. | int | 16000 |[1,...]| medium |
76
77
77
78
79
+
78
80
### Custom pipelines
79
81
80
82
The following example can be used to only observe inserted files:
0 commit comments