From ff98127235aac42d78eaf36f5e48e211e3d994b9 Mon Sep 17 00:00:00 2001 From: Jakob Edding <15202881+JakobEdding@users.noreply.github.com> Date: Tue, 2 Jan 2024 17:36:31 +0100 Subject: [PATCH] Update AvroDeadLetterConverter example from deprecated transformer style to processor style --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 5f92877..8fce386 100644 --- a/README.md +++ b/README.md @@ -77,7 +77,7 @@ final KStream input = final KStream> mappedWithErrors = input.map(captureErrors(mapper)); mappedWithErrors.flatMap(ProcessedKeyValue::getErrors) - .transformValues(AvroDeadLetterConverter.asTransformer("A good description where the pipeline broke")) + .processValues(AvroDeadLetterConverter.asProcessor("A good description where the pipeline broke")) .to(ERROR_TOPIC); final KStream mapped = mappedWithErrors.flatMapValues(ProcessedKeyValue::getValues); @@ -90,7 +90,7 @@ This error topic contains dead letters describing the input value, error message The example uses the `AvroDeadLetterConverter` from `error-handling-avro`. Analogously, `error-handling-proto` implements a `ProtoDeadLetterConverter`. -A custom `DeadLetterConverter` can be passed to `DeadLetterTransformer.create`. +A custom `DeadLetterConverter` can be passed to `DeadLetterProcessor.create`. ## Development