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
Copy file name to clipboardExpand all lines: source/kafka-sink-properties.txt
+10-5Lines changed: 10 additions & 5 deletions
Original file line number
Diff line number
Diff line change
@@ -98,7 +98,7 @@ data to sink to MongoDB. For an example configuration file, see
98
98
|
99
99
| **Default**: ``false``
100
100
| **Accepted Values**: ``true`` or ``false``
101
-
101
+
102
102
* - document.id.strategy.uuid.format
103
103
- string
104
104
- | Whether the connector should output the UUID in the ``_id`` field as a string or in the `BsonBinary <https://mongodb.github.io/mongo-java-driver/4.1/apidocs/bson/org/bson/BsonBinary.html>`__ format.
@@ -238,7 +238,7 @@ data to sink to MongoDB. For an example configuration file, see
238
238
- | The maximum number of tasks that should be created for this connector. The connector may create fewer tasks if it cannot handle the specified level of parallelism.
239
239
240
240
.. important:: Messages May Be Processed Out of Order For Values Greater Than 1
241
-
241
+
242
242
If you specify a value greater than ``1``, the connector
243
243
enables parallel processing of the tasks. If your topic has
244
244
multiple partition logs (allows consumers to read from the
@@ -250,16 +250,21 @@ data to sink to MongoDB. For an example configuration file, see
250
250
* - heartbeat.interval.ms
251
251
- int
252
252
- | The length of time in milliseconds between sending heartbeat
253
-
messages to record the post batch resume token when no source
254
-
records have been published. Improves the resumability of the
253
+
messages. Heartbeat messages contain the post batch resume token
254
+
and are sent when no source records have been published in the
255
+
specified interval. This improves the resumability of the
255
256
connector for low volume namespaces. Use ``0`` to disable.
256
257
|
257
258
| **Default**: ``0``
258
259
| **Accepted Values**: An integer
259
260
260
261
* - heartbeat.topic.name
261
262
- string
262
-
- | The name of the topic to publish heartbeat messages to.
263
+
- | The name of the topic to publish heartbeat messages to. To enable
264
+
the heartbeat feature, you must provide a positive value in the
265
+
``heartbeat.interval.ms`` setting. The user must consume
266
+
messages on this topic to track the latest offset (post batch
0 commit comments