Skip to content

Commit 1a443f7

Browse files
committed
Doc polishing for the previous commit
1 parent 6dd162c commit 1a443f7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/reference/asciidoc/kafka.adoc

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4872,8 +4872,9 @@ There are two mechanisms to add more headers.
48724872

48734873
1. Subclass the recoverer and override `createProducerRecord()` - call `super.createProducerRecord()` and add more headers.
48744874
2. Provide a `BiFunction` to receive the consumer record and exception, returning a `Headers` object; headers from there will be copied to the final producer record.
4875+
Use `setHeadersFunction()` to set the `BiFunction`.
48754876

4876-
The second is simpler to implement but the first has more information, including the already assembled standard headers.
4877+
The second is simpler to implement but the first has more information available, including the already assembled standard headers.
48774878

48784879
Starting with version 2.3, when used in conjunction with an `ErrorHandlingDeserializer`, the publisher will restore the record `value()`, in the dead-letter producer record, to the original value that failed to be deserialized.
48794880
Previously, the `value()` was null and user code had to decode the `DeserializationException` from the message headers.

0 commit comments

Comments
 (0)