|
2 | 2 | What's New
|
3 | 3 | ==========
|
4 | 4 |
|
5 |
| -abc |
| 5 | +.. default-domain:: mongodb |
| 6 | + |
| 7 | +.. contents:: On this page |
| 8 | + :local: |
| 9 | + :backlinks: none |
| 10 | + :depth: 1 |
| 11 | + :class: singlecol |
| 12 | + |
| 13 | +Learn what's new in a particular version: |
| 14 | + |
| 15 | +* :ref:`Version 1.6 <kafka-connector-whats-new-1.6>` |
| 16 | +* :ref:`Version 1.5 <kafka-connector-whats-new-1.5>` |
| 17 | +* :ref:`Version 1.4 <kafka-connector-whats-new-1.4>` |
| 18 | +* :ref:`Version 1.3 <kafka-connector-whats-new-1.3>` |
| 19 | +* :ref:`Version 1.2 <kafka-connector-whats-new-1.2>` |
| 20 | +* :ref:`Version 1.1 <kafka-connector-whats-new-1.1>` |
| 21 | +* :ref:`Version 1.0 <kafka-connector-whats-new-1.0>` |
| 22 | + |
| 23 | +.. _kafka-connector-whats-new-1.6: |
| 24 | + |
| 25 | +What's New in 1.6 |
| 26 | +----------------- |
| 27 | + |
| 28 | +- Added support for Versioned API to force the server to run operations with behavior compatible with the specified API version |
| 29 | +- Added error handling properties that can override the Connect framework's error handling behavior |
| 30 | +- Added ``mongo-kafka-connect-<version>-confluent.jar`` which contains the connector and all dependencies needed to run it on the Confluent Platform |
| 31 | + |
| 32 | +Sink Connector |
| 33 | +~~~~~~~~~~~~~~ |
| 34 | + |
| 35 | +- Added support for automatic time-series collection creation in MongoDB 5.0 to efficiently store sequences of measurements over a period of time |
| 36 | +- Improved the error logging for bulk write exceptions |
| 37 | + |
| 38 | +Source Connector |
| 39 | +~~~~~~~~~~~~~~~~ |
| 40 | + |
| 41 | +- No new changes, additions or improvements |
| 42 | + |
| 43 | +Bug Fixes |
| 44 | +~~~~~~~~~ |
| 45 | + |
| 46 | +- Corrected the behavior of ``LazyBsonDocument#clone`` to respond to any changes made once unwrapped |
| 47 | +- 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 |
| 50 | + |
| 51 | +.. _kafka-connector-whats-new-1.5: |
| 52 | + |
| 53 | +What's New in 1.5 |
| 54 | +----------------- |
| 55 | + |
| 56 | +- Updated the MongoDB Java Driver to version 4.2 |
| 57 | + |
| 58 | +Sink Connector |
| 59 | +~~~~~~~~~~~~~~ |
| 60 | + |
| 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 |
| 64 | + |
| 65 | +Source Connector |
| 66 | +~~~~~~~~~~~~~~~~ |
| 67 | + |
| 68 | +- Replaced ``BsonDocument`` with ``RawBsonDocument`` |
| 69 | +- Improved the ``copy.existing`` namespace handling |
| 70 | +- Improved the error messages for invalid pipeline operators |
| 71 | +- Improved the efficiency of heartbeats by making them tombstone messages |
| 72 | + |
| 73 | +Bug Fixes |
| 74 | +~~~~~~~~~ |
| 75 | + |
| 76 | +- Corrected the inferred schema naming conventions |
| 77 | +- Updated to ensure that schemas can be backwards compatible |
| 78 | +- Fixed the Sink validation issue with ``topics.regex`` |
| 79 | +- 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 |
| 82 | + |
| 83 | +.. _kafka-connector-whats-new-1.4: |
| 84 | + |
| 85 | +What's New in 1.4 |
| 86 | +----------------- |
| 87 | + |
| 88 | +- Updated the MongoDB Java Driver to version 4.1 |
| 89 | + |
| 90 | +Sink Connector |
| 91 | +~~~~~~~~~~~~~~ |
| 92 | + |
| 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 |
| 95 | + |
| 96 | +Source Connector |
| 97 | +~~~~~~~~~~~~~~~~ |
| 98 | + |
| 99 | +- Added the ``TopicMapper`` interface to allow topic mapping |
| 100 | + |
| 101 | +Bug Fixes |
| 102 | +~~~~~~~~~ |
| 103 | + |
| 104 | +- 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`` |
| 108 | + |
| 109 | +.. _kafka-connector-whats-new-1.3: |
| 110 | + |
| 111 | +What's New in 1.3 |
| 112 | +----------------- |
| 113 | + |
| 114 | +- Added automated integration testing for the latest Kafka Connector and Confluent Platform versions to ensure compatibility |
| 115 | + |
| 116 | +Sink Connector |
| 117 | +~~~~~~~~~~~~~~ |
| 118 | + |
| 119 | +- Added support for records that contain ``Bson`` byte types |
| 120 | +- Added support for the ``errors.tolerance`` property |
| 121 | +- Changed ``max.num.retries`` default to ``1`` |
| 122 | +- Improved the error messages for business key errors |
| 123 | +- Improved the error handling for ``List`` and JSON array configuration options |
| 124 | +- Updated to use the dot notation for filters in key update strategies |
| 125 | + |
| 126 | +Source Connector |
| 127 | +~~~~~~~~~~~~~~~~ |
| 128 | + |
| 129 | +- Added support to output a key or value as a ``Bson`` byte type |
| 130 | +- Added support for schema and custom Avro schema definitions |
| 131 | +- 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 |
| 136 | +- 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 |
| 138 | +- Updated to disable publishing a source record without a topic name |
| 139 | + |
| 140 | +Bug Fixes |
| 141 | +~~~~~~~~~ |
| 142 | + |
| 143 | +- Stopped MongoDB 3.6 from copying existing issues when the collection doesn't exist in the Source Connector |
| 144 | + |
| 145 | +.. _kafka-connector-whats-new-1.2: |
| 146 | + |
| 147 | +What's New in 1.2 |
| 148 | +----------------- |
| 149 | + |
| 150 | +Sink Connector |
| 151 | +~~~~~~~~~~~~~~ |
| 152 | + |
| 153 | +.. important:: |
| 154 | + |
| 155 | + We deprecated the following post processors: |
| 156 | + ``BlacklistKeyProjector``, ``BlacklistValueProjector``, |
| 157 | + ``WhitelistKeyProjector`` and ``WhitelistValueProjector``. |
| 158 | + |
| 159 | + If you are using one of these post processors, use the |
| 160 | + ``BlockListKeyProjector``, ``BlockListValueProjector``, |
| 161 | + ``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`` |
| 165 | +- Added the ``UpdateOneBusinessKeyTimestampStrategy`` post processor |
| 166 | +- Added built-in support for parallelism and scalable data copying by assigning topic partitions to tasks |
| 167 | + |
| 168 | +Source Connector |
| 169 | +~~~~~~~~~~~~~~~~ |
| 170 | + |
| 171 | +- Improved the error messaging for missing resume tokens |
| 172 | + |
| 173 | +Bug Fixes |
| 174 | +~~~~~~~~~ |
| 175 | + |
| 176 | +- Removed failures with the ``MongoCopyDataManager`` when the source database does not exist |
| 177 | +- Fixed the copying the existing resumability error in the Source Connector |
| 178 | + |
| 179 | +.. _kafka-connector-whats-new-1.1: |
| 180 | + |
| 181 | +What's New in 1.1 |
| 182 | +----------------- |
| 183 | + |
| 184 | +Sink Connector |
| 185 | +~~~~~~~~~~~~~~ |
| 186 | + |
| 187 | +- Added support for the ``topics.regex`` property |
| 188 | +- Updated to ignore unused source record key or value fields |
| 189 | +- Added validation for the connection using ``MongoSìnkConnector.validate`` |
| 190 | + |
| 191 | +Source Connector |
| 192 | +~~~~~~~~~~~~~~~~ |
| 193 | + |
| 194 | +- Added validation for the connection using ``MongoSourceConnector.validate`` |
| 195 | + |
| 196 | +Bug Fixes |
| 197 | +~~~~~~~~~ |
| 198 | + |
| 199 | +- Removed the ``"Unrecognized field: startAfter"`` error for resuming a change stream in the Source Connector |
| 200 | + |
| 201 | +.. _kafka-connector-whats-new-1.0: |
| 202 | + |
| 203 | +What's New in 1.0 |
| 204 | +----------------- |
| 205 | + |
| 206 | +The initial GA release. |
0 commit comments