From 346a0023f87256b2e9e63f4ce76948e115ee970b Mon Sep 17 00:00:00 2001 From: Jakob Edding <15202881+JakobEdding@users.noreply.github.com> Date: Wed, 3 Jan 2024 09:16:21 +0100 Subject: [PATCH] Update AvroDeadLetterConverter example from deprecated transformer style to processor style (#22) --- 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