Skip to content

Commit e4d6496

Browse files
kyuan-mongodbschmalliso
authored andcommitted
DOCSP-15401 Errant Record Reporting (#95)
* added information about errant record reporting
1 parent 890f581 commit e4d6496

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

source/kafka-sink-properties.txt

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -355,16 +355,16 @@ You can use the following settings to customize the behavior of the
355355
Dead Letter Queue Configuration Settings
356356
----------------------------------------
357357

358-
Kafka connectors send messages that cannot be processed to the **dead letter
359-
queue**. The connector sends invalid messages to this queue in order to
360-
allow manual inspection, updates, and re-submission for processing. It is
361-
disabled by default and requires restarting the connector for the changes to
362-
the configuration to take effect.
358+
Apache Kafka version 2.6 added support for handling errant records that
359+
cause problems when processing them. The Kafka connector automatically
360+
sends messages that it cannot process to the **dead letter queue** to
361+
allow you to inspect them manually, update them, and resubmit them for
362+
processing.
363363

364364
The following is an example configuration for enabling the dead letter queue
365-
topic ``example.deadletterqueue`` that specifies that both the invalid
366-
message as well as the log file should record invalid messages, and that
367-
context headers should be included in the dead letter queue messages.
365+
topic ``example.deadletterqueue``. It specifies for the invalid message
366+
as well as the log file to record invalid messages, and to include
367+
context headers in the dead letter queue messages.
368368

369369
.. code-block:: properties
370370

0 commit comments

Comments
 (0)