diff --git a/v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java b/v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java index 3967957206..34b8e5700b 100644 --- a/v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java +++ b/v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java @@ -35,7 +35,7 @@ public interface ReadSubscriptionOptions extends PipelineOptions { groupName = "Source", description = "Pub/Sub input subscription", helpText = "The Pub/Sub input subscription to read from.", - example = "projects//subscription/") + example = "projects//subscriptions/") @Required String getInputSubscription();