File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -298,13 +298,16 @@ sent to the DLQ.
298298 MarkLogic then each of the records in the batch will be sent to the DLQ. The entire batch must be sent to the DLQ since
299299 the connector is unable to determine the cause of the failure.
300300
301- When a record is sent to the DLQ, the connector first adds headers to the record providing information about the cause
301+ When a record is sent to the DLQ, the connector first adds headers to the record, providing information about the cause
302302of the failure in order to assist with troubleshooting and potential routing.
303303- "marklogic-failure-type" : Either "Write failure" or "Record conversion"
304304- "marklogic-exception-message" : Information from MarkLogic when there is a write failure
305305- "marklogic-original-topic" : The name of the topic that this record came from
306306- "marklogic-target-uri" : For write failures, this contains the target URI for the document
307307
308+ For those headers to be populated properly, the version of this connector must be compatible with the version of Kafka
309+ that is being used. The 1.8.0 and 1.9.0 versions of the connector work with Kafka versions before 3.8. Starting with
310+ the connector version 1.10.0, the Kafka version must be 3.8 or later.
308311
309312## Sink connector error handling
310313
You can’t perform that action at this time.
0 commit comments