File tree Expand file tree Collapse file tree 5 files changed +42
-2
lines changed Expand file tree Collapse file tree 5 files changed +42
-2
lines changed Original file line number Diff line number Diff line change 1
1
define: prefix docs/kafka-connector
2
2
define: base https://www.mongodb.com/${prefix}
3
3
4
- define: versions v1.0 v1.1 v1.2 v1.3 v1.4 v1.5 v1.6 v1.7 v1.8 v1.9 v1.10 v1.11 master
4
+ define: versions v1.0 v1.1 v1.2 v1.3 v1.4 v1.5 v1.6 v1.7 v1.8 v1.9 v1.10 v1.11 v1.12 master
5
5
6
6
symlink: current -> master
7
7
Original file line number Diff line number Diff line change @@ -15,7 +15,7 @@ avro = "Avro"
15
15
avro-converter =" Kafka Connect Avro Converter (Avro Converter)"
16
16
protobuf-converter =" Kafka Connect Protobuf Converter"
17
17
json-schema-converter =" Kafka Connect JSON Schema Converter"
18
- connector_version =" 1.11 "
18
+ connector_version =" 1.12 "
19
19
connector_patch_version =" 2"
20
20
connector_driver_version =" 4.7"
21
21
connector_version_github_tag =" master"
Original file line number Diff line number Diff line change @@ -10,6 +10,13 @@ Connector Error Handling Properties
10
10
:depth: 2
11
11
:class: singlecol
12
12
13
+ .. facet::
14
+ :name: genre
15
+ :values: reference
16
+
17
+ .. meta::
18
+ :keywords: errors, options, configure
19
+
13
20
Overview
14
21
--------
15
22
@@ -44,6 +51,8 @@ Settings
44
51
| When set to ``none``, the connector reports any error and
45
52
blocks further processing of the rest of the messages.
46
53
| When set to ``all``, the connector ignores any problematic messages.
54
+ | When set to ``data``, the connector tolerates only data errors and
55
+ fails on all other errors.
47
56
| To learn more about error handling strategies, see the
48
57
:ref:`<kafka-sink-handle-errors>` page.
49
58
Original file line number Diff line number Diff line change @@ -10,6 +10,13 @@ Error Handling
10
10
:depth: 2
11
11
:class: singlecol
12
12
13
+ .. facet::
14
+ :name: genre
15
+ :values: reference
16
+
17
+ .. meta::
18
+ :keywords: sink, processing
19
+
13
20
Overview
14
21
--------
15
22
@@ -90,6 +97,20 @@ option:
90
97
you lose less data. To learn more about bulk write operations, see
91
98
the :ref:`Write Model Strategies page <sink-connector-bulk-write-ops>`.
92
99
100
+ Tolerate Data Errors
101
+ ~~~~~~~~~~~~~~~~~~~~
102
+
103
+ You can configure your sink connector to tolerate only data errors, and stop
104
+ processing for all others. With this setting, the connector sends data errors to the dead
105
+ letter queue if one is configured.
106
+
107
+ Configure your sink connector to tolerate only data errors by specifying the
108
+ following option:
109
+
110
+ .. code-block:: properties
111
+
112
+ errors.tolerance=data
113
+
93
114
.. _kafka-sink-errors-dlq:
94
115
95
116
Write Errors and Errant Messages to a Topic
Original file line number Diff line number Diff line change @@ -19,6 +19,7 @@ What's New
19
19
20
20
Learn what's new by version:
21
21
22
+ * :ref:`Version 1.12 <kafka-connector-whats-new-1.12>`
22
23
* :ref:`Version 1.11.2 <kafka-connector-whats-new-1.11.2>`
23
24
* :ref:`Version 1.11.1 <kafka-connector-whats-new-1.11.1>`
24
25
* :ref:`Version 1.11 <kafka-connector-whats-new-1.11>`
@@ -38,6 +39,15 @@ Learn what's new by version:
38
39
* :ref:`Version 1.1 <kafka-connector-whats-new-1.1>`
39
40
* :ref:`Version 1.0 <kafka-connector-whats-new-1.0>`
40
41
42
+ .. _kafka-connector-whats-new-1.12:
43
+
44
+ What's New in 1.12
45
+ ------------------
46
+
47
+ - Added support for a ``data`` configuration value in the ``mongo.errors.tolerance``
48
+ configuration setting. With ``mongo.errors.tolerance=data``, the sink
49
+ connector tolerates only data errors, and fails for any others.
50
+
41
51
.. _kafka-connector-whats-new-1.11.2:
42
52
43
53
What's New in 1.11.2
You can’t perform that action at this time.
0 commit comments