Add pipeline description

akvelon · Feb 23, 2024 · 12f8e66 · 12f8e66
1 parent fd5ab2e
commit 12f8e66
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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=";