File tree 1 file changed +4
-1
lines changed
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.
298
298
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
299
299
the connector is unable to determine the cause of the failure.
300
300
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
302
302
of the failure in order to assist with troubleshooting and potential routing.
303
303
- "marklogic-failure-type" : Either "Write failure" or "Record conversion"
304
304
- "marklogic-exception-message" : Information from MarkLogic when there is a write failure
305
305
- "marklogic-original-topic" : The name of the topic that this record came from
306
306
- "marklogic-target-uri" : For write failures, this contains the target URI for the document
307
307
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.
308
311
309
312
## Sink connector error handling
310
313
You can’t perform that action at this time.
0 commit comments