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
and :ref:`source connector <source-configuration-error-handling>`
49
+
that can override the Kafka Connect framework's error handling behavior
50
+
- Added ``mongo-kafka-connect-<version>-confluent.jar``, which contains
51
+
the connector and all dependencies needed to run it on the Confluent Platform
31
52
32
53
Sink Connector
33
54
~~~~~~~~~~~~~~
34
55
35
-
- Added support for automatic time-series collection creation in MongoDB 5.0 to efficiently store sequences of measurements over a period of time
56
+
- Added support for :ref:`automatic time-series collection creation <sink-configuration-time-series>`
57
+
in MongoDB 5.0 to efficiently store sequences of measurements over a period
58
+
of time
36
59
- Improved the error logging for bulk write exceptions
37
60
38
61
Source Connector
@@ -43,24 +66,31 @@ Source Connector
43
66
Bug Fixes
44
67
~~~~~~~~~
45
68
46
-
- Corrected the behavior of ``LazyBsonDocument#clone`` to respond to any changes made once unwrapped
69
+
- Corrected the behavior of ``LazyBsonDocument#clone`` to respond to any
70
+
changes made once unwrapped
47
71
- Fixed the timestamp integer overflow in the Source Connector
48
-
- Updated to enable recovery when calling the ``getMore()`` method in the Source Connector
49
-
- Updated to enable recovery from broken change stream due to event sizes that are greater than 16MB in the Source Connector
72
+
- Updated to enable recovery when calling the ``getMore()`` method in the
73
+
Source Connector
74
+
- Updated to enable recovery from broken change stream due to event sizes that
75
+
are greater than 16 MB in the Source Connector
76
+
50
77
51
78
.. _kafka-connector-whats-new-1.5:
52
79
53
80
What's New in 1.5
54
81
-----------------
55
82
56
-
- Updated the MongoDB Java Driver to version 4.2
83
+
- Updated the MongoDB Java driver dependency to version 4.2
57
84
58
85
Sink Connector
59
86
~~~~~~~~~~~~~~
60
87
61
-
- Added the ``DeleteOneBusinessKeyStrategy`` write strategy to remove records from a topic
62
-
- Added support for handling errant records that cause problems when processing them
63
-
- Added support for Qlik Replicate Change Data Capture (CDC) to process event streams
88
+
- Added the ``DeleteOneBusinessKeyStrategy`` write strategy to remove records
89
+
from a topic
90
+
- Added support for handling errant records that cause problems when
91
+
processing them
92
+
- Added support for Qlik Replicate Change Data Capture (CDC) to process event
93
+
streams
64
94
65
95
Source Connector
66
96
~~~~~~~~~~~~~~~~
@@ -73,12 +103,14 @@ Source Connector
73
103
Bug Fixes
74
104
~~~~~~~~~
75
105
76
-
- Corrected the inferred schema naming conventions
106
+
- Corrected the inferred schema naming conventions
77
107
- Updated to ensure that schemas can be backwards compatible
78
-
- Fixed the Sink validation issue with ``topics.regex``
108
+
- Fixed the Sink validation issue with ``topics.regex``
79
109
- Fixed the Sink NPE issue when using with Confluent Connect 6.1.0
80
-
- Updated to ensure that the change stream cursor closes so it only reports errors that exist
81
-
- Changed to include or exclude the ``_id`` field for a projection only if it's explicitly added
110
+
- Updated to ensure that the change stream cursor closes so it only reports
111
+
errors that exist
112
+
- Changed to include or exclude the ``_id`` field for a projection only if
113
+
it's explicitly added
82
114
83
115
.. _kafka-connector-whats-new-1.4:
84
116
@@ -90,8 +122,10 @@ What's New in 1.4
90
122
Sink Connector
91
123
~~~~~~~~~~~~~~
92
124
93
-
- Added support for Change Data Capture (CDC) based on MongoDB change stream events
94
-
- Added the ``NamespaceMapper`` interface to allow for dynamic namespace mapping
125
+
- Added support for Change Data Capture (CDC) based on MongoDB change stream
126
+
events
127
+
- Added the ``NamespaceMapper`` interface to allow for dynamic namespace
128
+
mapping
95
129
96
130
Source Connector
97
131
~~~~~~~~~~~~~~~~
@@ -102,16 +136,19 @@ Bug Fixes
102
136
~~~~~~~~~
103
137
104
138
- Changed the top-level inferred schema to be mandatory
105
-
- Fixed a validation issue and synthetic configuration property in the Sink Connector
106
-
- Corrected general exception logging
107
-
- Updated to clone the ``LazyBsonDocument`` instead of the unwrapped ``BsonDocument``
139
+
- Fixed a validation issue and synthetic configuration property in the Sink
140
+
Connector
141
+
- Corrected general exception logging
142
+
- Updated to clone the ``LazyBsonDocument`` instead of the unwrapped
143
+
``BsonDocument``
108
144
109
145
.. _kafka-connector-whats-new-1.3:
110
146
111
147
What's New in 1.3
112
148
-----------------
113
149
114
-
- Added automated integration testing for the latest Kafka Connector and Confluent Platform versions to ensure compatibility
150
+
- Added automated integration testing for the latest Kafka Connector and
151
+
Confluent Platform versions to ensure compatibility
115
152
116
153
Sink Connector
117
154
~~~~~~~~~~~~~~
@@ -129,18 +166,29 @@ Source Connector
129
166
- Added support to output a key or value as a ``Bson`` byte type
130
167
- Added support for schema and custom Avro schema definitions
131
168
- Added support for dead letter queue and the ``errors.tolerance`` property
132
-
- Added configurations for the following formatters: ``DefaultJson``, ``ExtendedJson``, ``SimplifiedJson``
133
-
- Added configuration for ``copy.existing.pipeline`` to allow you to use indexes during the copying process
134
-
- Added configuration for ``copy.existing.namespace.regex`` to allow you to copy the filtering of namespaces
135
-
- Added configuration for ``offset.partition.name`` to allow for custom partitioning naming strategies
169
+
- Added configurations for the following formatters:
170
+
171
+
- ``DefaultJson``
172
+
- ``ExtendedJson``
173
+
- ``SimplifiedJson``
174
+
175
+
- Added configuration for ``copy.existing.pipeline`` to allow you to use
176
+
indexes during the copying process
177
+
- Added configuration for ``copy.existing.namespace.regex`` to allow you to
178
+
copy the filtering of namespaces
179
+
- Added configuration for ``offset.partition.name`` to allow for custom
180
+
partitioning naming strategies
136
181
- Updated to validate that the ``fullDocument`` field is a document
137
-
- Updated to sanitize the connection string in the offset partition map to improve maintenance of the ``connection.uri``, ``database`` and ``collection`` parameters
182
+
- Updated to sanitize the connection string in the offset partition map to
183
+
improve maintenance of the ``connection.uri``, ``database``, and
184
+
``collection`` parameters
138
185
- Updated to disable publishing a source record without a topic name
139
186
140
187
Bug Fixes
141
188
~~~~~~~~~
142
189
143
-
- Stopped MongoDB 3.6 from copying existing issues when the collection doesn't exist in the Source Connector
190
+
- Stopped MongoDB 3.6 from copying existing issues when the collection
``AllowListKeyProjector`` and ``AllowListValueProjector`` instead for
162
-
future compatibility.
163
-
164
-
- Added configurations for the following properties: ``document.id.strategy.overwrite.existing``, ``UuidStrategy`` output types, ``document.id.strategy.partial.value.projection.type``, ``document.id.strategy.partial.value.projection.list``, ``document.id.strategy.partial.key.projection.type``, ``document.id.strategy.partial.key.projection.list``, ``UuidProvidedInKeyStrategy``, and ``UuidProvidedInValueStrategy``
204
+
205
+
- ``BlacklistKeyProjector``
206
+
- ``BlacklistValueProjector``
207
+
- ``WhitelistKeyProjector``
208
+
- ``WhitelistValueProjector``
209
+
210
+
If you are using one of these post processors, use the respective one
211
+
instead for future compatibility:
212
+
213
+
- ``BlockListKeyProjector``
214
+
- ``BlockListValueProjector``,
215
+
- ``AllowListKeyProjector``
216
+
- ``AllowListValueProjector``
217
+
218
+
- Added configurations for the following properties:
0 commit comments