diff --git a/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java b/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java index a12feab5..7ea752b0 100644 --- a/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java +++ b/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java @@ -331,7 +331,7 @@ public interface ProjectNameBuilder { /** Part of {@link PubSubSinkBuilder} to set required fields. */ public interface TopicNameBuilder { - /** Set the subscription name of the subscription to pull messages from. */ + /** Set the name of the topic where the messages will be published. */ PubSubSinkBuilder withTopicName(String topicName); }