File tree Expand file tree Collapse file tree 4 files changed +18
-6
lines changed
sink-connector/configuration-properties Expand file tree Collapse file tree 4 files changed +18
-6
lines changed Original file line number Diff line number Diff line change
1
+ .. note :: Data Copy Can Produce Duplicate Events
2
+
3
+ If any system changes the data in the database while the source connector
4
+ converts existing data from it, MongoDB may produce duplicate change
5
+ stream events to reflect the latest changes. Since the change stream
6
+ events on which the data copy relies are idempotent, the copied data is
7
+ eventually consistent.
Original file line number Diff line number Diff line change @@ -40,10 +40,10 @@ Settings
40
40
|
41
41
| Consider the batch that contains the following records:
42
42
43
- .. code-block:: none
44
- :copyable: false
43
+ .. code-block:: none
44
+ :copyable: false
45
45
46
- [ 1, 2, 3, 4, 5 ]
46
+ [ 1, 2, 3, 4, 5 ]
47
47
48
48
| When set to ``0``, the connector performs a single bulk write for
49
49
the entire batch.
@@ -52,10 +52,10 @@ Settings
52
52
record in the batch, for a total of five bulk writes as shown in
53
53
the following example:
54
54
55
- .. code-block:: none
56
- :copyable: false
55
+ .. code-block:: none
56
+ :copyable: false
57
57
58
- [1], [2], [3], [4], [5]
58
+ [1], [2], [3], [4], [5]
59
59
60
60
| **Default**: ``0``
61
61
| **Accepted Values**: An integer
Original file line number Diff line number Diff line change @@ -45,6 +45,9 @@ Settings
45
45
collection data after the connector starts the copy process, the
46
46
connector creates events for the changes after it completes the copy
47
47
process.
48
+
49
+ .. include:: /includes/copy-existing-admonition.rst
50
+
48
51
| **Default**:``false``
49
52
| **Accepted Values**: ``true`` or ``false``
50
53
Original file line number Diff line number Diff line change @@ -67,6 +67,8 @@ specifying the following configuration options in your source connector:
67
67
Your source connector copies your collection by creating change event documents
68
68
that describe inserting each document into your collection.
69
69
70
+ .. include:: /includes/copy-existing-admonition.rst
71
+
70
72
To learn more about change event documents, see the
71
73
:ref:`Change Streams <source-connector-fundamentals-change-event>` guide.
72
74
You can’t perform that action at this time.
0 commit comments