From 12f8e66df5eeb11d0a76a88e79bcc756eb77e16c Mon Sep 17 00:00:00 2001 From: "vitaly.terentyev" Date: Fri, 23 Feb 2024 19:12:51 +0400 Subject: [PATCH] Add pipeline description --- .../src/main/java/pubsub/ReadWithDeadLetterTopicPubSub.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/Java/src/main/java/pubsub/ReadWithDeadLetterTopicPubSub.java b/Java/src/main/java/pubsub/ReadWithDeadLetterTopicPubSub.java index dd6e109..eedb074 100644 --- a/Java/src/main/java/pubsub/ReadWithDeadLetterTopicPubSub.java +++ b/Java/src/main/java/pubsub/ReadWithDeadLetterTopicPubSub.java @@ -27,6 +27,12 @@ import java.nio.charset.StandardCharsets; +/** + * Pipeline for reading messages from Google Cloud Pub/Sub, incorporating error handling through a + * dead-letter topic. The pipeline uses the {@code PubsubIO.readStrings()} transform to read + * messages from a specified subscription, and any parsing errors are captured and redirected to a + * dead-letter topic. + */ public class ReadWithDeadLetterTopicPubSub { public static final String ID_EXAMPLE_SUFFIX = "id=";