diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
index 20d06d3d9..b5c7b51c7 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java
@@ -1071,10 +1071,12 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
    *
    * @param subscription Required. The subscription from which messages should be pulled. Format is
    *     `projects/{project}/subscriptions/{sub}`.
-   * @param returnImmediately If this field set to true, the system will respond immediately even if
-   *     it there are no messages available to return in the `Pull` response. Otherwise, the system
-   *     may wait (for a bounded amount of time) until at least one message is available, rather
-   *     than returning no messages.
+   * @param returnImmediately Optional. If this field set to true, the system will respond
+   *     immediately even if it there are no messages available to return in the `Pull` response.
+   *     Otherwise, the system may wait (for a bounded amount of time) until at least one message is
+   *     available, rather than returning no messages. Warning: setting this field to `true` is
+   *     discouraged because it adversely impacts the performance of `Pull` operations. We recommend
+   *     that users do not set this field.
    * @param maxMessages Required. The maximum number of messages to return for this request. Must be
    *     a positive integer. The Pub/Sub system may return fewer than the number specified.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -1108,10 +1110,12 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
    *
    * @param subscription Required. The subscription from which messages should be pulled. Format is
    *     `projects/{project}/subscriptions/{sub}`.
-   * @param returnImmediately If this field set to true, the system will respond immediately even if
-   *     it there are no messages available to return in the `Pull` response. Otherwise, the system
-   *     may wait (for a bounded amount of time) until at least one message is available, rather
-   *     than returning no messages.
+   * @param returnImmediately Optional. If this field set to true, the system will respond
+   *     immediately even if it there are no messages available to return in the `Pull` response.
+   *     Otherwise, the system may wait (for a bounded amount of time) until at least one message is
+   *     available, rather than returning no messages. Warning: setting this field to `true` is
+   *     discouraged because it adversely impacts the performance of `Pull` operations. We recommend
+   *     that users do not set this field.
    * @param maxMessages Required. The maximum number of messages to return for this request. Must be
    *     a positive integer. The Pub/Sub system may return fewer than the number specified.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequest.java
index abfe740a5..e29a1fcca 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequest.java
@@ -185,8 +185,9 @@ public com.google.protobuf.ByteString getSubscriptionBytes() {
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -200,8 +201,9 @@ public com.google.protobuf.ProtocolStringList getAckIdsList() {
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -215,8 +217,9 @@ public int getAckIdsCount() {
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -231,8 +234,9 @@ public java.lang.String getAckIds(int index) {
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -729,8 +733,9 @@ private void ensureAckIdsIsMutable() {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -744,8 +749,9 @@ public com.google.protobuf.ProtocolStringList getAckIdsList() {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -759,8 +765,9 @@ public int getAckIdsCount() {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -775,8 +782,9 @@ public java.lang.String getAckIds(int index) {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -791,8 +799,9 @@ public com.google.protobuf.ByteString getAckIdsBytes(int index) {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -814,8 +823,9 @@ public Builder setAckIds(int index, java.lang.String value) {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -836,8 +846,9 @@ public Builder addAckIds(java.lang.String value) {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -855,8 +866,9 @@ public Builder addAllAckIds(java.lang.Iterable<java.lang.String> values) {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -873,8 +885,9 @@ public Builder clearAckIds() {
      *
      *
      * <pre>
-     * Required. The acknowledgment ID for the messages being acknowledged that was returned
-     * by the Pub/Sub system in the `Pull` response. Must not be empty.
+     * Required. The acknowledgment ID for the messages being acknowledged that
+     * was returned by the Pub/Sub system in the `Pull` response. Must not be
+     * empty.
      * </pre>
      *
      * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequestOrBuilder.java
index 294551012..4951b0bb1 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/AcknowledgeRequestOrBuilder.java
@@ -58,8 +58,9 @@ public interface AcknowledgeRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -71,8 +72,9 @@ public interface AcknowledgeRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -84,8 +86,9 @@ public interface AcknowledgeRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
@@ -98,8 +101,9 @@ public interface AcknowledgeRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The acknowledgment ID for the messages being acknowledged that was returned
-   * by the Pub/Sub system in the `Pull` response. Must not be empty.
+   * Required. The acknowledgment ID for the messages being acknowledged that
+   * was returned by the Pub/Sub system in the `Pull` response. Must not be
+   * empty.
    * </pre>
    *
    * <code>repeated string ack_ids = 2 [(.google.api.field_behavior) = REQUIRED];</code>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequest.java
index ae660b8f1..9c6e4bd87 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequest.java
@@ -150,10 +150,10 @@ protected com.google.protobuf.MapField internalGetMapField(int number) {
    *
    *
    * <pre>
-   * Required. User-provided name for this snapshot. If the name is not provided in the
-   * request, the server will assign a random name for this snapshot on the same
-   * project as the subscription. Note that for REST API requests, you must
-   * specify a name.  See the &lt;a
+   * Required. User-provided name for this snapshot. If the name is not provided
+   * in the request, the server will assign a random name for this snapshot on
+   * the same project as the subscription. Note that for REST API requests, you
+   * must specify a name.  See the &lt;a
    * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
    * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
    * </pre>
@@ -179,10 +179,10 @@ public java.lang.String getName() {
    *
    *
    * <pre>
-   * Required. User-provided name for this snapshot. If the name is not provided in the
-   * request, the server will assign a random name for this snapshot on the same
-   * project as the subscription. Note that for REST API requests, you must
-   * specify a name.  See the &lt;a
+   * Required. User-provided name for this snapshot. If the name is not provided
+   * in the request, the server will assign a random name for this snapshot on
+   * the same project as the subscription. Note that for REST API requests, you
+   * must specify a name.  See the &lt;a
    * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
    * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
    * </pre>
@@ -750,10 +750,10 @@ public Builder mergeFrom(
      *
      *
      * <pre>
-     * Required. User-provided name for this snapshot. If the name is not provided in the
-     * request, the server will assign a random name for this snapshot on the same
-     * project as the subscription. Note that for REST API requests, you must
-     * specify a name.  See the &lt;a
+     * Required. User-provided name for this snapshot. If the name is not provided
+     * in the request, the server will assign a random name for this snapshot on
+     * the same project as the subscription. Note that for REST API requests, you
+     * must specify a name.  See the &lt;a
      * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
      * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
      * </pre>
@@ -779,10 +779,10 @@ public java.lang.String getName() {
      *
      *
      * <pre>
-     * Required. User-provided name for this snapshot. If the name is not provided in the
-     * request, the server will assign a random name for this snapshot on the same
-     * project as the subscription. Note that for REST API requests, you must
-     * specify a name.  See the &lt;a
+     * Required. User-provided name for this snapshot. If the name is not provided
+     * in the request, the server will assign a random name for this snapshot on
+     * the same project as the subscription. Note that for REST API requests, you
+     * must specify a name.  See the &lt;a
      * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
      * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
      * </pre>
@@ -808,10 +808,10 @@ public com.google.protobuf.ByteString getNameBytes() {
      *
      *
      * <pre>
-     * Required. User-provided name for this snapshot. If the name is not provided in the
-     * request, the server will assign a random name for this snapshot on the same
-     * project as the subscription. Note that for REST API requests, you must
-     * specify a name.  See the &lt;a
+     * Required. User-provided name for this snapshot. If the name is not provided
+     * in the request, the server will assign a random name for this snapshot on
+     * the same project as the subscription. Note that for REST API requests, you
+     * must specify a name.  See the &lt;a
      * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
      * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
      * </pre>
@@ -836,10 +836,10 @@ public Builder setName(java.lang.String value) {
      *
      *
      * <pre>
-     * Required. User-provided name for this snapshot. If the name is not provided in the
-     * request, the server will assign a random name for this snapshot on the same
-     * project as the subscription. Note that for REST API requests, you must
-     * specify a name.  See the &lt;a
+     * Required. User-provided name for this snapshot. If the name is not provided
+     * in the request, the server will assign a random name for this snapshot on
+     * the same project as the subscription. Note that for REST API requests, you
+     * must specify a name.  See the &lt;a
      * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
      * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
      * </pre>
@@ -860,10 +860,10 @@ public Builder clearName() {
      *
      *
      * <pre>
-     * Required. User-provided name for this snapshot. If the name is not provided in the
-     * request, the server will assign a random name for this snapshot on the same
-     * project as the subscription. Note that for REST API requests, you must
-     * specify a name.  See the &lt;a
+     * Required. User-provided name for this snapshot. If the name is not provided
+     * in the request, the server will assign a random name for this snapshot on
+     * the same project as the subscription. Note that for REST API requests, you
+     * must specify a name.  See the &lt;a
      * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
      * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
      * </pre>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
index ab50a6f1b..b8e0ef2f9 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
@@ -27,10 +27,10 @@ public interface CreateSnapshotRequestOrBuilder
    *
    *
    * <pre>
-   * Required. User-provided name for this snapshot. If the name is not provided in the
-   * request, the server will assign a random name for this snapshot on the same
-   * project as the subscription. Note that for REST API requests, you must
-   * specify a name.  See the &lt;a
+   * Required. User-provided name for this snapshot. If the name is not provided
+   * in the request, the server will assign a random name for this snapshot on
+   * the same project as the subscription. Note that for REST API requests, you
+   * must specify a name.  See the &lt;a
    * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
    * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
    * </pre>
@@ -46,10 +46,10 @@ public interface CreateSnapshotRequestOrBuilder
    *
    *
    * <pre>
-   * Required. User-provided name for this snapshot. If the name is not provided in the
-   * request, the server will assign a random name for this snapshot on the same
-   * project as the subscription. Note that for REST API requests, you must
-   * specify a name.  See the &lt;a
+   * Required. User-provided name for this snapshot. If the name is not provided
+   * in the request, the server will assign a random name for this snapshot on
+   * the same project as the subscription. Note that for REST API requests, you
+   * must specify a name.  See the &lt;a
    * href="https://cloud.google.com/pubsub/docs/admin#resource_names"&gt; resource
    * name rules&lt;/a&gt;. Format is `projects/{project}/snapshots/{snap}`.
    * </pre>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequest.java
index 353db1071..5e59b993c 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequest.java
@@ -130,11 +130,13 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
    *
    *
    * <pre>
-   * The name of the topic that snapshots are attached to.
+   * Required. The name of the topic that snapshots are attached to.
    * Format is `projects/{project}/topics/{topic}`.
    * </pre>
    *
-   * <code>string topic = 1;</code>
+   * <code>
+   * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+   * </code>
    *
    * @return The topic.
    */
@@ -153,11 +155,13 @@ public java.lang.String getTopic() {
    *
    *
    * <pre>
-   * The name of the topic that snapshots are attached to.
+   * Required. The name of the topic that snapshots are attached to.
    * Format is `projects/{project}/topics/{topic}`.
    * </pre>
    *
-   * <code>string topic = 1;</code>
+   * <code>
+   * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+   * </code>
    *
    * @return The bytes for topic.
    */
@@ -593,11 +597,13 @@ public Builder mergeFrom(
      *
      *
      * <pre>
-     * The name of the topic that snapshots are attached to.
+     * Required. The name of the topic that snapshots are attached to.
      * Format is `projects/{project}/topics/{topic}`.
      * </pre>
      *
-     * <code>string topic = 1;</code>
+     * <code>
+     * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+     * </code>
      *
      * @return The topic.
      */
@@ -616,11 +622,13 @@ public java.lang.String getTopic() {
      *
      *
      * <pre>
-     * The name of the topic that snapshots are attached to.
+     * Required. The name of the topic that snapshots are attached to.
      * Format is `projects/{project}/topics/{topic}`.
      * </pre>
      *
-     * <code>string topic = 1;</code>
+     * <code>
+     * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+     * </code>
      *
      * @return The bytes for topic.
      */
@@ -639,11 +647,13 @@ public com.google.protobuf.ByteString getTopicBytes() {
      *
      *
      * <pre>
-     * The name of the topic that snapshots are attached to.
+     * Required. The name of the topic that snapshots are attached to.
      * Format is `projects/{project}/topics/{topic}`.
      * </pre>
      *
-     * <code>string topic = 1;</code>
+     * <code>
+     * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+     * </code>
      *
      * @param value The topic to set.
      * @return This builder for chaining.
@@ -661,11 +671,13 @@ public Builder setTopic(java.lang.String value) {
      *
      *
      * <pre>
-     * The name of the topic that snapshots are attached to.
+     * Required. The name of the topic that snapshots are attached to.
      * Format is `projects/{project}/topics/{topic}`.
      * </pre>
      *
-     * <code>string topic = 1;</code>
+     * <code>
+     * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+     * </code>
      *
      * @return This builder for chaining.
      */
@@ -679,11 +691,13 @@ public Builder clearTopic() {
      *
      *
      * <pre>
-     * The name of the topic that snapshots are attached to.
+     * Required. The name of the topic that snapshots are attached to.
      * Format is `projects/{project}/topics/{topic}`.
      * </pre>
      *
-     * <code>string topic = 1;</code>
+     * <code>
+     * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+     * </code>
      *
      * @param value The bytes for topic to set.
      * @return This builder for chaining.
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequestOrBuilder.java
index 484ea34c2..3e3382705 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicSnapshotsRequestOrBuilder.java
@@ -27,11 +27,13 @@ public interface ListTopicSnapshotsRequestOrBuilder
    *
    *
    * <pre>
-   * The name of the topic that snapshots are attached to.
+   * Required. The name of the topic that snapshots are attached to.
    * Format is `projects/{project}/topics/{topic}`.
    * </pre>
    *
-   * <code>string topic = 1;</code>
+   * <code>
+   * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+   * </code>
    *
    * @return The topic.
    */
@@ -40,11 +42,13 @@ public interface ListTopicSnapshotsRequestOrBuilder
    *
    *
    * <pre>
-   * The name of the topic that snapshots are attached to.
+   * Required. The name of the topic that snapshots are attached to.
    * Format is `projects/{project}/topics/{topic}`.
    * </pre>
    *
-   * <code>string topic = 1;</code>
+   * <code>
+   * string topic = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+   * </code>
    *
    * @return The bytes for topic.
    */
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequest.java
index c2a92e215..76bbfe4b6 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequest.java
@@ -251,10 +251,10 @@ public com.google.protobuf.ByteString getAckIdsBytes(int index) {
    *
    *
    * <pre>
-   * Required. The new ack deadline with respect to the time this request was sent to
-   * the Pub/Sub system. For example, if the value is 10, the new
-   * ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-   * was made. Specifying zero might immediately make the message available for
+   * Required. The new ack deadline with respect to the time this request was
+   * sent to the Pub/Sub system. For example, if the value is 10, the new ack
+   * deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+   * made. Specifying zero might immediately make the message available for
    * delivery to another subscriber client. This typically results in an
    * increase in the rate of message redeliveries (that is, duplicates).
    * The minimum deadline you can specify is 0 seconds.
@@ -930,10 +930,10 @@ public Builder addAckIdsBytes(com.google.protobuf.ByteString value) {
      *
      *
      * <pre>
-     * Required. The new ack deadline with respect to the time this request was sent to
-     * the Pub/Sub system. For example, if the value is 10, the new
-     * ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-     * was made. Specifying zero might immediately make the message available for
+     * Required. The new ack deadline with respect to the time this request was
+     * sent to the Pub/Sub system. For example, if the value is 10, the new ack
+     * deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+     * made. Specifying zero might immediately make the message available for
      * delivery to another subscriber client. This typically results in an
      * increase in the rate of message redeliveries (that is, duplicates).
      * The minimum deadline you can specify is 0 seconds.
@@ -951,10 +951,10 @@ public int getAckDeadlineSeconds() {
      *
      *
      * <pre>
-     * Required. The new ack deadline with respect to the time this request was sent to
-     * the Pub/Sub system. For example, if the value is 10, the new
-     * ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-     * was made. Specifying zero might immediately make the message available for
+     * Required. The new ack deadline with respect to the time this request was
+     * sent to the Pub/Sub system. For example, if the value is 10, the new ack
+     * deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+     * made. Specifying zero might immediately make the message available for
      * delivery to another subscriber client. This typically results in an
      * increase in the rate of message redeliveries (that is, duplicates).
      * The minimum deadline you can specify is 0 seconds.
@@ -976,10 +976,10 @@ public Builder setAckDeadlineSeconds(int value) {
      *
      *
      * <pre>
-     * Required. The new ack deadline with respect to the time this request was sent to
-     * the Pub/Sub system. For example, if the value is 10, the new
-     * ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-     * was made. Specifying zero might immediately make the message available for
+     * Required. The new ack deadline with respect to the time this request was
+     * sent to the Pub/Sub system. For example, if the value is 10, the new ack
+     * deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+     * made. Specifying zero might immediately make the message available for
      * delivery to another subscriber client. This typically results in an
      * increase in the rate of message redeliveries (that is, duplicates).
      * The minimum deadline you can specify is 0 seconds.
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequestOrBuilder.java
index eacaf0964..663ca36d9 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ModifyAckDeadlineRequestOrBuilder.java
@@ -109,10 +109,10 @@ public interface ModifyAckDeadlineRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The new ack deadline with respect to the time this request was sent to
-   * the Pub/Sub system. For example, if the value is 10, the new
-   * ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-   * was made. Specifying zero might immediately make the message available for
+   * Required. The new ack deadline with respect to the time this request was
+   * sent to the Pub/Sub system. For example, if the value is 10, the new ack
+   * deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+   * made. Specifying zero might immediately make the message available for
    * delivery to another subscriber client. This typically results in an
    * increase in the rate of message redeliveries (that is, duplicates).
    * The minimum deadline you can specify is 0 seconds.
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
index 9320aa828..44f66abf3 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
@@ -225,13 +225,13 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
   static {
     java.lang.String[] descriptorData = {
       "\n\035google/pubsub/v1/pubsub.proto\022\020google."
-          + "pubsub.v1\032\027google/api/client.proto\032\037goog"
-          + "le/api/field_behavior.proto\032\031google/api/"
-          + "resource.proto\032\036google/protobuf/duration"
-          + ".proto\032\033google/protobuf/empty.proto\032 goo"
-          + "gle/protobuf/field_mask.proto\032\037google/pr"
-          + "otobuf/timestamp.proto\032\034google/api/annot"
-          + "ations.proto\";\n\024MessageStoragePolicy\022#\n\033"
+          + "pubsub.v1\032\034google/api/annotations.proto\032"
+          + "\027google/api/client.proto\032\037google/api/fie"
+          + "ld_behavior.proto\032\031google/api/resource.p"
+          + "roto\032\036google/protobuf/duration.proto\032\033go"
+          + "ogle/protobuf/empty.proto\032 google/protob"
+          + "uf/field_mask.proto\032\037google/protobuf/tim"
+          + "estamp.proto\";\n\024MessageStoragePolicy\022#\n\033"
           + "allowed_persistence_regions\030\001 \003(\t\"\262\002\n\005To"
           + "pic\022\021\n\004name\030\001 \001(\tB\003\340A\002\0223\n\006labels\030\002 \003(\0132#"
           + ".google.pubsub.v1.Topic.LabelsEntry\022F\n\026m"
@@ -267,221 +267,223 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "n\030\003 \001(\t\"y\n\036ListTopicSubscriptionsRespons"
           + "e\022>\n\rsubscriptions\030\001 \003(\tB\'\372A$\n\"pubsub.go"
           + "ogleapis.com/Subscription\022\027\n\017next_page_t"
-          + "oken\030\002 \001(\t\"Q\n\031ListTopicSnapshotsRequest\022"
-          + "\r\n\005topic\030\001 \001(\t\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npag"
-          + "e_token\030\003 \001(\t\"H\n\032ListTopicSnapshotsRespo"
-          + "nse\022\021\n\tsnapshots\030\001 \003(\t\022\027\n\017next_page_toke"
-          + "n\030\002 \001(\t\"H\n\022DeleteTopicRequest\0222\n\005topic\030\001"
-          + " \001(\tB#\340A\002\372A\035\n\033pubsub.googleapis.com/Topi"
-          + "c\"\351\004\n\014Subscription\022\021\n\004name\030\001 \001(\tB\003\340A\002\0222\n"
-          + "\005topic\030\002 \001(\tB#\340A\002\372A\035\n\033pubsub.googleapis."
-          + "com/Topic\0221\n\013push_config\030\004 \001(\0132\034.google."
-          + "pubsub.v1.PushConfig\022\034\n\024ack_deadline_sec"
-          + "onds\030\005 \001(\005\022\035\n\025retain_acked_messages\030\007 \001("
-          + "\010\022=\n\032message_retention_duration\030\010 \001(\0132\031."
-          + "google.protobuf.Duration\022:\n\006labels\030\t \003(\013"
-          + "2*.google.pubsub.v1.Subscription.LabelsE"
-          + "ntry\022\037\n\027enable_message_ordering\030\n \001(\010\022=\n"
-          + "\021expiration_policy\030\013 \001(\0132\".google.pubsub"
-          + ".v1.ExpirationPolicy\022>\n\022dead_letter_poli"
-          + "cy\030\r \001(\0132\".google.pubsub.v1.DeadLetterPo"
-          + "licy\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005valu"
-          + "e\030\002 \001(\t:\0028\001:X\352AU\n\"pubsub.googleapis.com/"
-          + "Subscription\022/projects/{project}/subscri"
-          + "ptions/{subscription}\"L\n\020DeadLetterPolic"
-          + "y\022\031\n\021dead_letter_topic\030\001 \001(\t\022\035\n\025max_deli"
-          + "very_attempts\030\002 \001(\005\":\n\020ExpirationPolicy\022"
-          + "&\n\003ttl\030\001 \001(\0132\031.google.protobuf.Duration\""
-          + "\255\002\n\nPushConfig\022\025\n\rpush_endpoint\030\001 \001(\t\022@\n"
-          + "\nattributes\030\002 \003(\0132,.google.pubsub.v1.Pus"
-          + "hConfig.AttributesEntry\022<\n\noidc_token\030\003 "
-          + "\001(\0132&.google.pubsub.v1.PushConfig.OidcTo"
-          + "kenH\000\032<\n\tOidcToken\022\035\n\025service_account_em"
-          + "ail\030\001 \001(\t\022\020\n\010audience\030\002 \001(\t\0321\n\017Attribute"
-          + "sEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001B\027"
-          + "\n\025authentication_method\"m\n\017ReceivedMessa"
-          + "ge\022\016\n\006ack_id\030\001 \001(\t\0220\n\007message\030\002 \001(\0132\037.go"
-          + "ogle.pubsub.v1.PubsubMessage\022\030\n\020delivery"
-          + "_attempt\030\003 \001(\005\"Z\n\026GetSubscriptionRequest"
-          + "\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.g"
-          + "oogleapis.com/Subscription\"\214\001\n\031UpdateSub"
-          + "scriptionRequest\0229\n\014subscription\030\001 \001(\0132\036"
-          + ".google.pubsub.v1.SubscriptionB\003\340A\002\0224\n\013u"
-          + "pdate_mask\030\002 \001(\0132\032.google.protobuf.Field"
-          + "MaskB\003\340A\002\"\207\001\n\030ListSubscriptionsRequest\022D"
-          + "\n\007project\030\001 \001(\tB3\340A\002\372A-\n+cloudresourcema"
-          + "nager.googleapis.com/Project\022\021\n\tpage_siz"
-          + "e\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"k\n\031ListSubsc"
-          + "riptionsResponse\0225\n\rsubscriptions\030\001 \003(\0132"
-          + "\036.google.pubsub.v1.Subscription\022\027\n\017next_"
-          + "page_token\030\002 \001(\t\"]\n\031DeleteSubscriptionRe"
-          + "quest\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pub"
-          + "sub.googleapis.com/Subscription\"\223\001\n\027Modi"
-          + "fyPushConfigRequest\022@\n\014subscription\030\001 \001("
-          + "\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Subscri"
-          + "ption\0226\n\013push_config\030\002 \001(\0132\034.google.pubs"
-          + "ub.v1.PushConfigB\003\340A\002\"\206\001\n\013PullRequest\022@\n"
+          + "oken\030\002 \001(\t\"v\n\031ListTopicSnapshotsRequest\022"
+          + "2\n\005topic\030\001 \001(\tB#\340A\002\372A\035\n\033pubsub.googleapi"
+          + "s.com/Topic\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_t"
+          + "oken\030\003 \001(\t\"H\n\032ListTopicSnapshotsResponse"
+          + "\022\021\n\tsnapshots\030\001 \003(\t\022\027\n\017next_page_token\030\002"
+          + " \001(\t\"H\n\022DeleteTopicRequest\0222\n\005topic\030\001 \001("
+          + "\tB#\340A\002\372A\035\n\033pubsub.googleapis.com/Topic\"\351"
+          + "\004\n\014Subscription\022\021\n\004name\030\001 \001(\tB\003\340A\002\0222\n\005to"
+          + "pic\030\002 \001(\tB#\340A\002\372A\035\n\033pubsub.googleapis.com"
+          + "/Topic\0221\n\013push_config\030\004 \001(\0132\034.google.pub"
+          + "sub.v1.PushConfig\022\034\n\024ack_deadline_second"
+          + "s\030\005 \001(\005\022\035\n\025retain_acked_messages\030\007 \001(\010\022="
+          + "\n\032message_retention_duration\030\010 \001(\0132\031.goo"
+          + "gle.protobuf.Duration\022:\n\006labels\030\t \003(\0132*."
+          + "google.pubsub.v1.Subscription.LabelsEntr"
+          + "y\022\037\n\027enable_message_ordering\030\n \001(\010\022=\n\021ex"
+          + "piration_policy\030\013 \001(\0132\".google.pubsub.v1"
+          + ".ExpirationPolicy\022>\n\022dead_letter_policy\030"
+          + "\r \001(\0132\".google.pubsub.v1.DeadLetterPolic"
+          + "y\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002"
+          + " \001(\t:\0028\001:X\352AU\n\"pubsub.googleapis.com/Sub"
+          + "scription\022/projects/{project}/subscripti"
+          + "ons/{subscription}\"L\n\020DeadLetterPolicy\022\031"
+          + "\n\021dead_letter_topic\030\001 \001(\t\022\035\n\025max_deliver"
+          + "y_attempts\030\002 \001(\005\":\n\020ExpirationPolicy\022&\n\003"
+          + "ttl\030\001 \001(\0132\031.google.protobuf.Duration\"\255\002\n"
+          + "\nPushConfig\022\025\n\rpush_endpoint\030\001 \001(\t\022@\n\nat"
+          + "tributes\030\002 \003(\0132,.google.pubsub.v1.PushCo"
+          + "nfig.AttributesEntry\022<\n\noidc_token\030\003 \001(\013"
+          + "2&.google.pubsub.v1.PushConfig.OidcToken"
+          + "H\000\032<\n\tOidcToken\022\035\n\025service_account_email"
+          + "\030\001 \001(\t\022\020\n\010audience\030\002 \001(\t\0321\n\017AttributesEn"
+          + "try\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001B\027\n\025a"
+          + "uthentication_method\"m\n\017ReceivedMessage\022"
+          + "\016\n\006ack_id\030\001 \001(\t\0220\n\007message\030\002 \001(\0132\037.googl"
+          + "e.pubsub.v1.PubsubMessage\022\030\n\020delivery_at"
+          + "tempt\030\003 \001(\005\"Z\n\026GetSubscriptionRequest\022@\n"
           + "\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.goog"
-          + "leapis.com/Subscription\022\032\n\022return_immedi"
-          + "ately\030\002 \001(\010\022\031\n\014max_messages\030\003 \001(\005B\003\340A\002\"L"
-          + "\n\014PullResponse\022<\n\021received_messages\030\001 \003("
-          + "\0132!.google.pubsub.v1.ReceivedMessage\"\225\001\n"
-          + "\030ModifyAckDeadlineRequest\022@\n\014subscriptio"
-          + "n\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/S"
-          + "ubscription\022\024\n\007ack_ids\030\004 \003(\tB\003\340A\002\022!\n\024ack"
-          + "_deadline_seconds\030\003 \001(\005B\003\340A\002\"l\n\022Acknowle"
-          + "dgeRequest\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$"
-          + "\n\"pubsub.googleapis.com/Subscription\022\024\n\007"
-          + "ack_ids\030\002 \003(\tB\003\340A\002\"\350\001\n\024StreamingPullRequ"
-          + "est\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsu"
-          + "b.googleapis.com/Subscription\022\017\n\007ack_ids"
-          + "\030\002 \003(\t\022\037\n\027modify_deadline_seconds\030\003 \003(\005\022"
-          + "\037\n\027modify_deadline_ack_ids\030\004 \003(\t\022(\n\033stre"
-          + "am_ack_deadline_seconds\030\005 \001(\005B\003\340A\002\022\021\n\tcl"
-          + "ient_id\030\006 \001(\t\"U\n\025StreamingPullResponse\022<"
-          + "\n\021received_messages\030\001 \003(\0132!.google.pubsu"
-          + "b.v1.ReceivedMessage\"\203\002\n\025CreateSnapshotR"
-          + "equest\0224\n\004name\030\001 \001(\tB&\340A\002\372A \n\036pubsub.goo"
-          + "gleapis.com/Snapshot\022@\n\014subscription\030\002 \001"
-          + "(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Subscr"
-          + "iption\022C\n\006labels\030\003 \003(\01323.google.pubsub.v"
-          + "1.CreateSnapshotRequest.LabelsEntry\032-\n\013L"
-          + "abelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002"
-          + "8\001\"\200\001\n\025UpdateSnapshotRequest\0221\n\010snapshot"
-          + "\030\001 \001(\0132\032.google.pubsub.v1.SnapshotB\003\340A\002\022"
-          + "4\n\013update_mask\030\002 \001(\0132\032.google.protobuf.F"
-          + "ieldMaskB\003\340A\002\"\257\002\n\010Snapshot\022\014\n\004name\030\001 \001(\t"
-          + "\022/\n\005topic\030\002 \001(\tB \372A\035\n\033pubsub.googleapis."
-          + "com/Topic\022/\n\013expire_time\030\003 \001(\0132\032.google."
-          + "protobuf.Timestamp\0226\n\006labels\030\004 \003(\0132&.goo"
-          + "gle.pubsub.v1.Snapshot.LabelsEntry\032-\n\013La"
-          + "belsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028"
-          + "\001:L\352AI\n\036pubsub.googleapis.com/Snapshot\022\'"
-          + "projects/{project}/snapshots/{snapshot}\""
-          + "N\n\022GetSnapshotRequest\0228\n\010snapshot\030\001 \001(\tB"
-          + "&\340A\002\372A \n\036pubsub.googleapis.com/Snapshot\""
-          + "\203\001\n\024ListSnapshotsRequest\022D\n\007project\030\001 \001("
-          + "\tB3\340A\002\372A-\n+cloudresourcemanager.googleap"
-          + "is.com/Project\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npag"
-          + "e_token\030\003 \001(\t\"_\n\025ListSnapshotsResponse\022-"
-          + "\n\tsnapshots\030\001 \003(\0132\032.google.pubsub.v1.Sna"
-          + "pshot\022\027\n\017next_page_token\030\002 \001(\t\"Q\n\025Delete"
-          + "SnapshotRequest\0228\n\010snapshot\030\001 \001(\tB&\340A\002\372A"
-          + " \n\036pubsub.googleapis.com/Snapshot\"\276\001\n\013Se"
-          + "ekRequest\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n"
-          + "\"pubsub.googleapis.com/Subscription\022*\n\004t"
-          + "ime\030\002 \001(\0132\032.google.protobuf.TimestampH\000\022"
-          + "7\n\010snapshot\030\003 \001(\tB#\372A \n\036pubsub.googleapi"
-          + "s.com/SnapshotH\000B\010\n\006target\"\016\n\014SeekRespon"
-          + "se2\353\t\n\tPublisher\022q\n\013CreateTopic\022\027.google"
-          + ".pubsub.v1.Topic\032\027.google.pubsub.v1.Topi"
-          + "c\"0\202\323\344\223\002#\032\036/v1/{name=projects/*/topics/*"
-          + "}:\001*\332A\004name\022}\n\013UpdateTopic\022$.google.pubs"
-          + "ub.v1.UpdateTopicRequest\032\027.google.pubsub"
-          + ".v1.Topic\"/\202\323\344\223\002)2$/v1/{topic.name=proje"
-          + "cts/*/topics/*}:\001*\022\223\001\n\007Publish\022 .google."
-          + "pubsub.v1.PublishRequest\032!.google.pubsub"
-          + ".v1.PublishResponse\"C\202\323\344\223\002,\"\'/v1/{topic="
-          + "projects/*/topics/*}:publish:\001*\332A\016topic,"
-          + "messages\022w\n\010GetTopic\022!.google.pubsub.v1."
-          + "GetTopicRequest\032\027.google.pubsub.v1.Topic"
-          + "\"/\202\323\344\223\002!\022\037/v1/{topic=projects/*/topics/*"
-          + "}\332A\005topic\022\212\001\n\nListTopics\022#.google.pubsub"
-          + ".v1.ListTopicsRequest\032$.google.pubsub.v1"
-          + ".ListTopicsResponse\"1\202\323\344\223\002!\022\037/v1/{projec"
-          + "t=projects/*}/topics\332A\007project\022\272\001\n\026ListT"
-          + "opicSubscriptions\022/.google.pubsub.v1.Lis"
-          + "tTopicSubscriptionsRequest\0320.google.pubs"
-          + "ub.v1.ListTopicSubscriptionsResponse\"=\202\323"
-          + "\344\223\002/\022-/v1/{topic=projects/*/topics/*}/su"
-          + "bscriptions\332A\005topic\022\242\001\n\022ListTopicSnapsho"
-          + "ts\022+.google.pubsub.v1.ListTopicSnapshots"
-          + "Request\032,.google.pubsub.v1.ListTopicSnap"
-          + "shotsResponse\"1\202\323\344\223\002+\022)/v1/{topic=projec"
-          + "ts/*/topics/*}/snapshots\022|\n\013DeleteTopic\022"
-          + "$.google.pubsub.v1.DeleteTopicRequest\032\026."
-          + "google.protobuf.Empty\"/\202\323\344\223\002!*\037/v1/{topi"
-          + "c=projects/*/topics/*}\332A\005topic\032p\312A\025pubsu"
-          + "b.googleapis.com\322AUhttps://www.googleapi"
-          + "s.com/auth/cloud-platform,https://www.go"
-          + "ogleapis.com/auth/pubsub2\367\024\n\nSubscriber\022"
-          + "\264\001\n\022CreateSubscription\022\036.google.pubsub.v"
-          + "1.Subscription\032\036.google.pubsub.v1.Subscr"
-          + "iption\"^\202\323\344\223\002*\032%/v1/{name=projects/*/sub"
-          + "scriptions/*}:\001*\332A+name,topic,push_confi"
-          + "g,ack_deadline_seconds\022\241\001\n\017GetSubscripti"
-          + "on\022(.google.pubsub.v1.GetSubscriptionReq"
-          + "uest\032\036.google.pubsub.v1.Subscription\"D\202\323"
-          + "\344\223\002/\022-/v1/{subscription=projects/*/subsc"
-          + "riptions/*}\332A\014subscription\022\240\001\n\022UpdateSub"
-          + "scription\022+.google.pubsub.v1.UpdateSubsc"
-          + "riptionRequest\032\036.google.pubsub.v1.Subscr"
-          + "iption\"=\202\323\344\223\002722/v1/{subscription.name=p"
-          + "rojects/*/subscriptions/*}:\001*\022\246\001\n\021ListSu"
-          + "bscriptions\022*.google.pubsub.v1.ListSubsc"
-          + "riptionsRequest\032+.google.pubsub.v1.ListS"
-          + "ubscriptionsResponse\"8\202\323\344\223\002(\022&/v1/{proje"
-          + "ct=projects/*}/subscriptions\332A\007project\022\237"
-          + "\001\n\022DeleteSubscription\022+.google.pubsub.v1"
-          + ".DeleteSubscriptionRequest\032\026.google.prot"
-          + "obuf.Empty\"D\202\323\344\223\002/*-/v1/{subscription=pr"
-          + "ojects/*/subscriptions/*}\332A\014subscription"
-          + "\022\317\001\n\021ModifyAckDeadline\022*.google.pubsub.v"
-          + "1.ModifyAckDeadlineRequest\032\026.google.prot"
-          + "obuf.Empty\"v\202\323\344\223\002D\"?/v1/{subscription=pr"
-          + "ojects/*/subscriptions/*}:modifyAckDeadl"
-          + "ine:\001*\332A)subscription,ack_ids,ack_deadli"
-          + "ne_seconds\022\250\001\n\013Acknowledge\022$.google.pubs"
-          + "ub.v1.AcknowledgeRequest\032\026.google.protob"
-          + "uf.Empty\"[\202\323\344\223\002>\"9/v1/{subscription=proj"
-          + "ects/*/subscriptions/*}:acknowledge:\001*\332A"
-          + "\024subscription,ack_ids\022\263\001\n\004Pull\022\035.google."
-          + "pubsub.v1.PullRequest\032\036.google.pubsub.v1"
-          + ".PullResponse\"l\202\323\344\223\0027\"2/v1/{subscription"
-          + "=projects/*/subscriptions/*}:pull:\001*\332A,s"
-          + "ubscription,return_immediately,max_messa"
-          + "ges\022f\n\rStreamingPull\022&.google.pubsub.v1."
-          + "StreamingPullRequest\032\'.google.pubsub.v1."
-          + "StreamingPullResponse\"\000(\0010\001\022\273\001\n\020ModifyPu"
-          + "shConfig\022).google.pubsub.v1.ModifyPushCo"
-          + "nfigRequest\032\026.google.protobuf.Empty\"d\202\323\344"
-          + "\223\002C\">/v1/{subscription=projects/*/subscr"
-          + "iptions/*}:modifyPushConfig:\001*\332A\030subscri"
-          + "ption,push_config\022~\n\013GetSnapshot\022$.googl"
-          + "e.pubsub.v1.GetSnapshotRequest\032\032.google."
-          + "pubsub.v1.Snapshot\"-\202\323\344\223\002\'\022%/v1/{snapsho"
-          + "t=projects/*/snapshots/*}\022\226\001\n\rListSnapsh"
-          + "ots\022&.google.pubsub.v1.ListSnapshotsRequ"
-          + "est\032\'.google.pubsub.v1.ListSnapshotsResp"
-          + "onse\"4\202\323\344\223\002$\022\"/v1/{project=projects/*}/s"
-          + "napshots\332A\007project\022\227\001\n\016CreateSnapshot\022\'."
-          + "google.pubsub.v1.CreateSnapshotRequest\032\032"
-          + ".google.pubsub.v1.Snapshot\"@\202\323\344\223\002&\032!/v1/"
-          + "{name=projects/*/snapshots/*}:\001*\332A\021name,"
-          + "subscription\022\214\001\n\016UpdateSnapshot\022\'.google"
-          + ".pubsub.v1.UpdateSnapshotRequest\032\032.googl"
-          + "e.pubsub.v1.Snapshot\"5\202\323\344\223\002/2*/v1/{snaps"
-          + "hot.name=projects/*/snapshots/*}:\001*\022\213\001\n\016"
-          + "DeleteSnapshot\022\'.google.pubsub.v1.Delete"
-          + "SnapshotRequest\032\026.google.protobuf.Empty\""
-          + "8\202\323\344\223\002\'*%/v1/{snapshot=projects/*/snapsh"
-          + "ots/*}\332A\010snapshot\022\204\001\n\004Seek\022\035.google.pubs"
-          + "ub.v1.SeekRequest\032\036.google.pubsub.v1.See"
-          + "kResponse\"=\202\323\344\223\0027\"2/v1/{subscription=pro"
-          + "jects/*/subscriptions/*}:seek:\001*\032p\312A\025pub"
-          + "sub.googleapis.com\322AUhttps://www.googlea"
-          + "pis.com/auth/cloud-platform,https://www."
-          + "googleapis.com/auth/pubsubB\256\001\n\024com.googl"
-          + "e.pubsub.v1B\013PubsubProtoP\001Z6google.golan"
-          + "g.org/genproto/googleapis/pubsub/v1;pubs"
-          + "ub\370\001\001\252\002\026Google.Cloud.PubSub.V1\312\002\026Google\\"
-          + "Cloud\\PubSub\\V1\352\002\031Google::Cloud::PubSub:"
-          + ":V1b\006proto3"
+          + "leapis.com/Subscription\"\214\001\n\031UpdateSubscr"
+          + "iptionRequest\0229\n\014subscription\030\001 \001(\0132\036.go"
+          + "ogle.pubsub.v1.SubscriptionB\003\340A\002\0224\n\013upda"
+          + "te_mask\030\002 \001(\0132\032.google.protobuf.FieldMas"
+          + "kB\003\340A\002\"\207\001\n\030ListSubscriptionsRequest\022D\n\007p"
+          + "roject\030\001 \001(\tB3\340A\002\372A-\n+cloudresourcemanag"
+          + "er.googleapis.com/Project\022\021\n\tpage_size\030\002"
+          + " \001(\005\022\022\n\npage_token\030\003 \001(\t\"k\n\031ListSubscrip"
+          + "tionsResponse\0225\n\rsubscriptions\030\001 \003(\0132\036.g"
+          + "oogle.pubsub.v1.Subscription\022\027\n\017next_pag"
+          + "e_token\030\002 \001(\t\"]\n\031DeleteSubscriptionReque"
+          + "st\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub"
+          + ".googleapis.com/Subscription\"\223\001\n\027ModifyP"
+          + "ushConfigRequest\022@\n\014subscription\030\001 \001(\tB*"
+          + "\340A\002\372A$\n\"pubsub.googleapis.com/Subscripti"
+          + "on\0226\n\013push_config\030\002 \001(\0132\034.google.pubsub."
+          + "v1.PushConfigB\003\340A\002\"\215\001\n\013PullRequest\022@\n\014su"
+          + "bscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googlea"
+          + "pis.com/Subscription\022!\n\022return_immediate"
+          + "ly\030\002 \001(\010B\005\030\001\340A\001\022\031\n\014max_messages\030\003 \001(\005B\003\340"
+          + "A\002\"L\n\014PullResponse\022<\n\021received_messages\030"
+          + "\001 \003(\0132!.google.pubsub.v1.ReceivedMessage"
+          + "\"\225\001\n\030ModifyAckDeadlineRequest\022@\n\014subscri"
+          + "ption\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.c"
+          + "om/Subscription\022\024\n\007ack_ids\030\004 \003(\tB\003\340A\002\022!\n"
+          + "\024ack_deadline_seconds\030\003 \001(\005B\003\340A\002\"l\n\022Ackn"
+          + "owledgeRequest\022@\n\014subscription\030\001 \001(\tB*\340A"
+          + "\002\372A$\n\"pubsub.googleapis.com/Subscription"
+          + "\022\024\n\007ack_ids\030\002 \003(\tB\003\340A\002\"\350\001\n\024StreamingPull"
+          + "Request\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"p"
+          + "ubsub.googleapis.com/Subscription\022\017\n\007ack"
+          + "_ids\030\002 \003(\t\022\037\n\027modify_deadline_seconds\030\003 "
+          + "\003(\005\022\037\n\027modify_deadline_ack_ids\030\004 \003(\t\022(\n\033"
+          + "stream_ack_deadline_seconds\030\005 \001(\005B\003\340A\002\022\021"
+          + "\n\tclient_id\030\006 \001(\t\"U\n\025StreamingPullRespon"
+          + "se\022<\n\021received_messages\030\001 \003(\0132!.google.p"
+          + "ubsub.v1.ReceivedMessage\"\203\002\n\025CreateSnaps"
+          + "hotRequest\0224\n\004name\030\001 \001(\tB&\340A\002\372A \n\036pubsub"
+          + ".googleapis.com/Snapshot\022@\n\014subscription"
+          + "\030\002 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Su"
+          + "bscription\022C\n\006labels\030\003 \003(\01323.google.pubs"
+          + "ub.v1.CreateSnapshotRequest.LabelsEntry\032"
+          + "-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001"
+          + "(\t:\0028\001\"\200\001\n\025UpdateSnapshotRequest\0221\n\010snap"
+          + "shot\030\001 \001(\0132\032.google.pubsub.v1.SnapshotB\003"
+          + "\340A\002\0224\n\013update_mask\030\002 \001(\0132\032.google.protob"
+          + "uf.FieldMaskB\003\340A\002\"\257\002\n\010Snapshot\022\014\n\004name\030\001"
+          + " \001(\t\022/\n\005topic\030\002 \001(\tB \372A\035\n\033pubsub.googlea"
+          + "pis.com/Topic\022/\n\013expire_time\030\003 \001(\0132\032.goo"
+          + "gle.protobuf.Timestamp\0226\n\006labels\030\004 \003(\0132&"
+          + ".google.pubsub.v1.Snapshot.LabelsEntry\032-"
+          + "\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001("
+          + "\t:\0028\001:L\352AI\n\036pubsub.googleapis.com/Snapsh"
+          + "ot\022\'projects/{project}/snapshots/{snapsh"
+          + "ot}\"N\n\022GetSnapshotRequest\0228\n\010snapshot\030\001 "
+          + "\001(\tB&\340A\002\372A \n\036pubsub.googleapis.com/Snaps"
+          + "hot\"\203\001\n\024ListSnapshotsRequest\022D\n\007project\030"
+          + "\001 \001(\tB3\340A\002\372A-\n+cloudresourcemanager.goog"
+          + "leapis.com/Project\022\021\n\tpage_size\030\002 \001(\005\022\022\n"
+          + "\npage_token\030\003 \001(\t\"_\n\025ListSnapshotsRespon"
+          + "se\022-\n\tsnapshots\030\001 \003(\0132\032.google.pubsub.v1"
+          + ".Snapshot\022\027\n\017next_page_token\030\002 \001(\t\"Q\n\025De"
+          + "leteSnapshotRequest\0228\n\010snapshot\030\001 \001(\tB&\340"
+          + "A\002\372A \n\036pubsub.googleapis.com/Snapshot\"\276\001"
+          + "\n\013SeekRequest\022@\n\014subscription\030\001 \001(\tB*\340A\002"
+          + "\372A$\n\"pubsub.googleapis.com/Subscription\022"
+          + "*\n\004time\030\002 \001(\0132\032.google.protobuf.Timestam"
+          + "pH\000\0227\n\010snapshot\030\003 \001(\tB#\372A \n\036pubsub.googl"
+          + "eapis.com/SnapshotH\000B\010\n\006target\"\016\n\014SeekRe"
+          + "sponse2\363\t\n\tPublisher\022q\n\013CreateTopic\022\027.go"
+          + "ogle.pubsub.v1.Topic\032\027.google.pubsub.v1."
+          + "Topic\"0\202\323\344\223\002#\032\036/v1/{name=projects/*/topi"
+          + "cs/*}:\001*\332A\004name\022}\n\013UpdateTopic\022$.google."
+          + "pubsub.v1.UpdateTopicRequest\032\027.google.pu"
+          + "bsub.v1.Topic\"/\202\323\344\223\002)2$/v1/{topic.name=p"
+          + "rojects/*/topics/*}:\001*\022\223\001\n\007Publish\022 .goo"
+          + "gle.pubsub.v1.PublishRequest\032!.google.pu"
+          + "bsub.v1.PublishResponse\"C\202\323\344\223\002,\"\'/v1/{to"
+          + "pic=projects/*/topics/*}:publish:\001*\332A\016to"
+          + "pic,messages\022w\n\010GetTopic\022!.google.pubsub"
+          + ".v1.GetTopicRequest\032\027.google.pubsub.v1.T"
+          + "opic\"/\202\323\344\223\002!\022\037/v1/{topic=projects/*/topi"
+          + "cs/*}\332A\005topic\022\212\001\n\nListTopics\022#.google.pu"
+          + "bsub.v1.ListTopicsRequest\032$.google.pubsu"
+          + "b.v1.ListTopicsResponse\"1\202\323\344\223\002!\022\037/v1/{pr"
+          + "oject=projects/*}/topics\332A\007project\022\272\001\n\026L"
+          + "istTopicSubscriptions\022/.google.pubsub.v1"
+          + ".ListTopicSubscriptionsRequest\0320.google."
+          + "pubsub.v1.ListTopicSubscriptionsResponse"
+          + "\"=\202\323\344\223\002/\022-/v1/{topic=projects/*/topics/*"
+          + "}/subscriptions\332A\005topic\022\252\001\n\022ListTopicSna"
+          + "pshots\022+.google.pubsub.v1.ListTopicSnaps"
+          + "hotsRequest\032,.google.pubsub.v1.ListTopic"
+          + "SnapshotsResponse\"9\202\323\344\223\002+\022)/v1/{topic=pr"
+          + "ojects/*/topics/*}/snapshots\332A\005topic\022|\n\013"
+          + "DeleteTopic\022$.google.pubsub.v1.DeleteTop"
+          + "icRequest\032\026.google.protobuf.Empty\"/\202\323\344\223\002"
+          + "!*\037/v1/{topic=projects/*/topics/*}\332A\005top"
+          + "ic\032p\312A\025pubsub.googleapis.com\322AUhttps://w"
+          + "ww.googleapis.com/auth/cloud-platform,ht"
+          + "tps://www.googleapis.com/auth/pubsub2\203\025\n"
+          + "\nSubscriber\022\264\001\n\022CreateSubscription\022\036.goo"
+          + "gle.pubsub.v1.Subscription\032\036.google.pubs"
+          + "ub.v1.Subscription\"^\202\323\344\223\002*\032%/v1/{name=pr"
+          + "ojects/*/subscriptions/*}:\001*\332A+name,topi"
+          + "c,push_config,ack_deadline_seconds\022\241\001\n\017G"
+          + "etSubscription\022(.google.pubsub.v1.GetSub"
+          + "scriptionRequest\032\036.google.pubsub.v1.Subs"
+          + "cription\"D\202\323\344\223\002/\022-/v1/{subscription=proj"
+          + "ects/*/subscriptions/*}\332A\014subscription\022\240"
+          + "\001\n\022UpdateSubscription\022+.google.pubsub.v1"
+          + ".UpdateSubscriptionRequest\032\036.google.pubs"
+          + "ub.v1.Subscription\"=\202\323\344\223\002722/v1/{subscri"
+          + "ption.name=projects/*/subscriptions/*}:\001"
+          + "*\022\246\001\n\021ListSubscriptions\022*.google.pubsub."
+          + "v1.ListSubscriptionsRequest\032+.google.pub"
+          + "sub.v1.ListSubscriptionsResponse\"8\202\323\344\223\002("
+          + "\022&/v1/{project=projects/*}/subscriptions"
+          + "\332A\007project\022\237\001\n\022DeleteSubscription\022+.goog"
+          + "le.pubsub.v1.DeleteSubscriptionRequest\032\026"
+          + ".google.protobuf.Empty\"D\202\323\344\223\002/*-/v1/{sub"
+          + "scription=projects/*/subscriptions/*}\332A\014"
+          + "subscription\022\317\001\n\021ModifyAckDeadline\022*.goo"
+          + "gle.pubsub.v1.ModifyAckDeadlineRequest\032\026"
+          + ".google.protobuf.Empty\"v\202\323\344\223\002D\"?/v1/{sub"
+          + "scription=projects/*/subscriptions/*}:mo"
+          + "difyAckDeadline:\001*\332A)subscription,ack_id"
+          + "s,ack_deadline_seconds\022\250\001\n\013Acknowledge\022$"
+          + ".google.pubsub.v1.AcknowledgeRequest\032\026.g"
+          + "oogle.protobuf.Empty\"[\202\323\344\223\002>\"9/v1/{subsc"
+          + "ription=projects/*/subscriptions/*}:ackn"
+          + "owledge:\001*\332A\024subscription,ack_ids\022\263\001\n\004Pu"
+          + "ll\022\035.google.pubsub.v1.PullRequest\032\036.goog"
+          + "le.pubsub.v1.PullResponse\"l\202\323\344\223\0027\"2/v1/{"
+          + "subscription=projects/*/subscriptions/*}"
+          + ":pull:\001*\332A,subscription,return_immediate"
+          + "ly,max_messages\022f\n\rStreamingPull\022&.googl"
+          + "e.pubsub.v1.StreamingPullRequest\032\'.googl"
+          + "e.pubsub.v1.StreamingPullResponse\"\000(\0010\001\022"
+          + "\273\001\n\020ModifyPushConfig\022).google.pubsub.v1."
+          + "ModifyPushConfigRequest\032\026.google.protobu"
+          + "f.Empty\"d\202\323\344\223\002C\">/v1/{subscription=proje"
+          + "cts/*/subscriptions/*}:modifyPushConfig:"
+          + "\001*\332A\030subscription,push_config\022\211\001\n\013GetSna"
+          + "pshot\022$.google.pubsub.v1.GetSnapshotRequ"
+          + "est\032\032.google.pubsub.v1.Snapshot\"8\202\323\344\223\002\'\022"
+          + "%/v1/{snapshot=projects/*/snapshots/*}\332A"
+          + "\010snapshot\022\226\001\n\rListSnapshots\022&.google.pub"
+          + "sub.v1.ListSnapshotsRequest\032\'.google.pub"
+          + "sub.v1.ListSnapshotsResponse\"4\202\323\344\223\002$\022\"/v"
+          + "1/{project=projects/*}/snapshots\332A\007proje"
+          + "ct\022\227\001\n\016CreateSnapshot\022\'.google.pubsub.v1"
+          + ".CreateSnapshotRequest\032\032.google.pubsub.v"
+          + "1.Snapshot\"@\202\323\344\223\002&\032!/v1/{name=projects/*"
+          + "/snapshots/*}:\001*\332A\021name,subscription\022\214\001\n"
+          + "\016UpdateSnapshot\022\'.google.pubsub.v1.Updat"
+          + "eSnapshotRequest\032\032.google.pubsub.v1.Snap"
+          + "shot\"5\202\323\344\223\002/2*/v1/{snapshot.name=project"
+          + "s/*/snapshots/*}:\001*\022\213\001\n\016DeleteSnapshot\022\'"
+          + ".google.pubsub.v1.DeleteSnapshotRequest\032"
+          + "\026.google.protobuf.Empty\"8\202\323\344\223\002\'*%/v1/{sn"
+          + "apshot=projects/*/snapshots/*}\332A\010snapsho"
+          + "t\022\204\001\n\004Seek\022\035.google.pubsub.v1.SeekReques"
+          + "t\032\036.google.pubsub.v1.SeekResponse\"=\202\323\344\223\002"
+          + "7\"2/v1/{subscription=projects/*/subscrip"
+          + "tions/*}:seek:\001*\032p\312A\025pubsub.googleapis.c"
+          + "om\322AUhttps://www.googleapis.com/auth/clo"
+          + "ud-platform,https://www.googleapis.com/a"
+          + "uth/pubsubB\256\001\n\024com.google.pubsub.v1B\013Pub"
+          + "subProtoP\001Z6google.golang.org/genproto/g"
+          + "oogleapis/pubsub/v1;pubsub\370\001\001\252\002\026Google.C"
+          + "loud.PubSub.V1\312\002\026Google\\Cloud\\PubSub\\V1\352"
+          + "\002\031Google::Cloud::PubSub::V1b\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
             descriptorData,
             new com.google.protobuf.Descriptors.FileDescriptor[] {
+              com.google.api.AnnotationsProto.getDescriptor(),
               com.google.api.ClientProto.getDescriptor(),
               com.google.api.FieldBehaviorProto.getDescriptor(),
               com.google.api.ResourceProto.getDescriptor(),
@@ -489,7 +491,6 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
               com.google.protobuf.EmptyProto.getDescriptor(),
               com.google.protobuf.FieldMaskProto.getDescriptor(),
               com.google.protobuf.TimestampProto.getDescriptor(),
-              com.google.api.AnnotationsProto.getDescriptor(),
             });
     internal_static_google_pubsub_v1_MessageStoragePolicy_descriptor =
         getDescriptor().getMessageTypes().get(0);
@@ -888,6 +889,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
     registry.add(com.google.api.ResourceProto.resourceReference);
     com.google.protobuf.Descriptors.FileDescriptor.internalUpdateFileDescriptor(
         descriptor, registry);
+    com.google.api.AnnotationsProto.getDescriptor();
     com.google.api.ClientProto.getDescriptor();
     com.google.api.FieldBehaviorProto.getDescriptor();
     com.google.api.ResourceProto.getDescriptor();
@@ -895,7 +897,6 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
     com.google.protobuf.EmptyProto.getDescriptor();
     com.google.protobuf.FieldMaskProto.getDescriptor();
     com.google.protobuf.TimestampProto.getDescriptor();
-    com.google.api.AnnotationsProto.getDescriptor();
   }
 
   // @@protoc_insertion_point(outer_class_scope)
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
index 2c6f5e56d..401fdeb0f 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
@@ -178,16 +178,21 @@ public com.google.protobuf.ByteString getSubscriptionBytes() {
    *
    *
    * <pre>
-   * If this field set to true, the system will respond immediately even if
-   * it there are no messages available to return in the `Pull` response.
-   * Otherwise, the system may wait (for a bounded amount of time) until at
-   * least one message is available, rather than returning no messages.
+   * Optional. If this field set to true, the system will respond immediately
+   * even if it there are no messages available to return in the `Pull`
+   * response. Otherwise, the system may wait (for a bounded amount of time)
+   * until at least one message is available, rather than returning no messages.
+   * Warning: setting this field to `true` is discouraged because it adversely
+   * impacts the performance of `Pull` operations. We recommend that users do
+   * not set this field.
    * </pre>
    *
-   * <code>bool return_immediately = 2;</code>
+   * <code>bool return_immediately = 2 [deprecated = true, (.google.api.field_behavior) = OPTIONAL];
+   * </code>
    *
    * @return The returnImmediately.
    */
+  @java.lang.Deprecated
   public boolean getReturnImmediately() {
     return returnImmediately_;
   }
@@ -198,8 +203,8 @@ public boolean getReturnImmediately() {
    *
    *
    * <pre>
-   * Required. The maximum number of messages to return for this request. Must be a
-   * positive integer. The Pub/Sub system may return fewer than the number
+   * Required. The maximum number of messages to return for this request. Must
+   * be a positive integer. The Pub/Sub system may return fewer than the number
    * specified.
    * </pre>
    *
@@ -680,16 +685,22 @@ public Builder setSubscriptionBytes(com.google.protobuf.ByteString value) {
      *
      *
      * <pre>
-     * If this field set to true, the system will respond immediately even if
-     * it there are no messages available to return in the `Pull` response.
-     * Otherwise, the system may wait (for a bounded amount of time) until at
-     * least one message is available, rather than returning no messages.
+     * Optional. If this field set to true, the system will respond immediately
+     * even if it there are no messages available to return in the `Pull`
+     * response. Otherwise, the system may wait (for a bounded amount of time)
+     * until at least one message is available, rather than returning no messages.
+     * Warning: setting this field to `true` is discouraged because it adversely
+     * impacts the performance of `Pull` operations. We recommend that users do
+     * not set this field.
      * </pre>
      *
-     * <code>bool return_immediately = 2;</code>
+     * <code>
+     * bool return_immediately = 2 [deprecated = true, (.google.api.field_behavior) = OPTIONAL];
+     * </code>
      *
      * @return The returnImmediately.
      */
+    @java.lang.Deprecated
     public boolean getReturnImmediately() {
       return returnImmediately_;
     }
@@ -697,17 +708,23 @@ public boolean getReturnImmediately() {
      *
      *
      * <pre>
-     * If this field set to true, the system will respond immediately even if
-     * it there are no messages available to return in the `Pull` response.
-     * Otherwise, the system may wait (for a bounded amount of time) until at
-     * least one message is available, rather than returning no messages.
+     * Optional. If this field set to true, the system will respond immediately
+     * even if it there are no messages available to return in the `Pull`
+     * response. Otherwise, the system may wait (for a bounded amount of time)
+     * until at least one message is available, rather than returning no messages.
+     * Warning: setting this field to `true` is discouraged because it adversely
+     * impacts the performance of `Pull` operations. We recommend that users do
+     * not set this field.
      * </pre>
      *
-     * <code>bool return_immediately = 2;</code>
+     * <code>
+     * bool return_immediately = 2 [deprecated = true, (.google.api.field_behavior) = OPTIONAL];
+     * </code>
      *
      * @param value The returnImmediately to set.
      * @return This builder for chaining.
      */
+    @java.lang.Deprecated
     public Builder setReturnImmediately(boolean value) {
 
       returnImmediately_ = value;
@@ -718,16 +735,22 @@ public Builder setReturnImmediately(boolean value) {
      *
      *
      * <pre>
-     * If this field set to true, the system will respond immediately even if
-     * it there are no messages available to return in the `Pull` response.
-     * Otherwise, the system may wait (for a bounded amount of time) until at
-     * least one message is available, rather than returning no messages.
+     * Optional. If this field set to true, the system will respond immediately
+     * even if it there are no messages available to return in the `Pull`
+     * response. Otherwise, the system may wait (for a bounded amount of time)
+     * until at least one message is available, rather than returning no messages.
+     * Warning: setting this field to `true` is discouraged because it adversely
+     * impacts the performance of `Pull` operations. We recommend that users do
+     * not set this field.
      * </pre>
      *
-     * <code>bool return_immediately = 2;</code>
+     * <code>
+     * bool return_immediately = 2 [deprecated = true, (.google.api.field_behavior) = OPTIONAL];
+     * </code>
      *
      * @return This builder for chaining.
      */
+    @java.lang.Deprecated
     public Builder clearReturnImmediately() {
 
       returnImmediately_ = false;
@@ -740,8 +763,8 @@ public Builder clearReturnImmediately() {
      *
      *
      * <pre>
-     * Required. The maximum number of messages to return for this request. Must be a
-     * positive integer. The Pub/Sub system may return fewer than the number
+     * Required. The maximum number of messages to return for this request. Must
+     * be a positive integer. The Pub/Sub system may return fewer than the number
      * specified.
      * </pre>
      *
@@ -756,8 +779,8 @@ public int getMaxMessages() {
      *
      *
      * <pre>
-     * Required. The maximum number of messages to return for this request. Must be a
-     * positive integer. The Pub/Sub system may return fewer than the number
+     * Required. The maximum number of messages to return for this request. Must
+     * be a positive integer. The Pub/Sub system may return fewer than the number
      * specified.
      * </pre>
      *
@@ -776,8 +799,8 @@ public Builder setMaxMessages(int value) {
      *
      *
      * <pre>
-     * Required. The maximum number of messages to return for this request. Must be a
-     * positive integer. The Pub/Sub system may return fewer than the number
+     * Required. The maximum number of messages to return for this request. Must
+     * be a positive integer. The Pub/Sub system may return fewer than the number
      * specified.
      * </pre>
      *
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
index a908386fb..eb88907a9 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
@@ -58,24 +58,29 @@ public interface PullRequestOrBuilder
    *
    *
    * <pre>
-   * If this field set to true, the system will respond immediately even if
-   * it there are no messages available to return in the `Pull` response.
-   * Otherwise, the system may wait (for a bounded amount of time) until at
-   * least one message is available, rather than returning no messages.
+   * Optional. If this field set to true, the system will respond immediately
+   * even if it there are no messages available to return in the `Pull`
+   * response. Otherwise, the system may wait (for a bounded amount of time)
+   * until at least one message is available, rather than returning no messages.
+   * Warning: setting this field to `true` is discouraged because it adversely
+   * impacts the performance of `Pull` operations. We recommend that users do
+   * not set this field.
    * </pre>
    *
-   * <code>bool return_immediately = 2;</code>
+   * <code>bool return_immediately = 2 [deprecated = true, (.google.api.field_behavior) = OPTIONAL];
+   * </code>
    *
    * @return The returnImmediately.
    */
+  @java.lang.Deprecated
   boolean getReturnImmediately();
 
   /**
    *
    *
    * <pre>
-   * Required. The maximum number of messages to return for this request. Must be a
-   * positive integer. The Pub/Sub system may return fewer than the number
+   * Required. The maximum number of messages to return for this request. Must
+   * be a positive integer. The Pub/Sub system may return fewer than the number
    * specified.
    * </pre>
    *
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java
index cf748b70c..6d30c9daf 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java
@@ -188,8 +188,8 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
    *
    *
    * <pre>
-   * Required. The subscription for which to initialize the new stream. This must be
-   * provided in the first request on the stream, and must not be set in
+   * Required. The subscription for which to initialize the new stream. This
+   * must be provided in the first request on the stream, and must not be set in
    * subsequent requests from client to server.
    * Format is `projects/{project}/subscriptions/{sub}`.
    * </pre>
@@ -215,8 +215,8 @@ public java.lang.String getSubscription() {
    *
    *
    * <pre>
-   * Required. The subscription for which to initialize the new stream. This must be
-   * provided in the first request on the stream, and must not be set in
+   * Required. The subscription for which to initialize the new stream. This
+   * must be provided in the first request on the stream, and must not be set in
    * subsequent requests from client to server.
    * Format is `projects/{project}/subscriptions/{sub}`.
    * </pre>
@@ -477,8 +477,8 @@ public com.google.protobuf.ByteString getModifyDeadlineAckIdsBytes(int index) {
    *
    *
    * <pre>
-   * Required. The ack deadline to use for the stream. This must be provided in the
-   * first request on the stream, but it can also be updated on subsequent
+   * Required. The ack deadline to use for the stream. This must be provided in
+   * the first request on the stream, but it can also be updated on subsequent
    * requests from client to server. The minimum deadline you can specify is 10
    * seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
    * </pre>
@@ -1016,8 +1016,8 @@ public Builder mergeFrom(
      *
      *
      * <pre>
-     * Required. The subscription for which to initialize the new stream. This must be
-     * provided in the first request on the stream, and must not be set in
+     * Required. The subscription for which to initialize the new stream. This
+     * must be provided in the first request on the stream, and must not be set in
      * subsequent requests from client to server.
      * Format is `projects/{project}/subscriptions/{sub}`.
      * </pre>
@@ -1043,8 +1043,8 @@ public java.lang.String getSubscription() {
      *
      *
      * <pre>
-     * Required. The subscription for which to initialize the new stream. This must be
-     * provided in the first request on the stream, and must not be set in
+     * Required. The subscription for which to initialize the new stream. This
+     * must be provided in the first request on the stream, and must not be set in
      * subsequent requests from client to server.
      * Format is `projects/{project}/subscriptions/{sub}`.
      * </pre>
@@ -1070,8 +1070,8 @@ public com.google.protobuf.ByteString getSubscriptionBytes() {
      *
      *
      * <pre>
-     * Required. The subscription for which to initialize the new stream. This must be
-     * provided in the first request on the stream, and must not be set in
+     * Required. The subscription for which to initialize the new stream. This
+     * must be provided in the first request on the stream, and must not be set in
      * subsequent requests from client to server.
      * Format is `projects/{project}/subscriptions/{sub}`.
      * </pre>
@@ -1096,8 +1096,8 @@ public Builder setSubscription(java.lang.String value) {
      *
      *
      * <pre>
-     * Required. The subscription for which to initialize the new stream. This must be
-     * provided in the first request on the stream, and must not be set in
+     * Required. The subscription for which to initialize the new stream. This
+     * must be provided in the first request on the stream, and must not be set in
      * subsequent requests from client to server.
      * Format is `projects/{project}/subscriptions/{sub}`.
      * </pre>
@@ -1118,8 +1118,8 @@ public Builder clearSubscription() {
      *
      *
      * <pre>
-     * Required. The subscription for which to initialize the new stream. This must be
-     * provided in the first request on the stream, and must not be set in
+     * Required. The subscription for which to initialize the new stream. This
+     * must be provided in the first request on the stream, and must not be set in
      * subsequent requests from client to server.
      * Format is `projects/{project}/subscriptions/{sub}`.
      * </pre>
@@ -1752,8 +1752,8 @@ public Builder addModifyDeadlineAckIdsBytes(com.google.protobuf.ByteString value
      *
      *
      * <pre>
-     * Required. The ack deadline to use for the stream. This must be provided in the
-     * first request on the stream, but it can also be updated on subsequent
+     * Required. The ack deadline to use for the stream. This must be provided in
+     * the first request on the stream, but it can also be updated on subsequent
      * requests from client to server. The minimum deadline you can specify is 10
      * seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
      * </pre>
@@ -1769,8 +1769,8 @@ public int getStreamAckDeadlineSeconds() {
      *
      *
      * <pre>
-     * Required. The ack deadline to use for the stream. This must be provided in the
-     * first request on the stream, but it can also be updated on subsequent
+     * Required. The ack deadline to use for the stream. This must be provided in
+     * the first request on the stream, but it can also be updated on subsequent
      * requests from client to server. The minimum deadline you can specify is 10
      * seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
      * </pre>
@@ -1790,8 +1790,8 @@ public Builder setStreamAckDeadlineSeconds(int value) {
      *
      *
      * <pre>
-     * Required. The ack deadline to use for the stream. This must be provided in the
-     * first request on the stream, but it can also be updated on subsequent
+     * Required. The ack deadline to use for the stream. This must be provided in
+     * the first request on the stream, but it can also be updated on subsequent
      * requests from client to server. The minimum deadline you can specify is 10
      * seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
      * </pre>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java
index daed9c34d..db56d7d25 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java
@@ -27,8 +27,8 @@ public interface StreamingPullRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The subscription for which to initialize the new stream. This must be
-   * provided in the first request on the stream, and must not be set in
+   * Required. The subscription for which to initialize the new stream. This
+   * must be provided in the first request on the stream, and must not be set in
    * subsequent requests from client to server.
    * Format is `projects/{project}/subscriptions/{sub}`.
    * </pre>
@@ -44,8 +44,8 @@ public interface StreamingPullRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The subscription for which to initialize the new stream. This must be
-   * provided in the first request on the stream, and must not be set in
+   * Required. The subscription for which to initialize the new stream. This
+   * must be provided in the first request on the stream, and must not be set in
    * subsequent requests from client to server.
    * Format is `projects/{project}/subscriptions/{sub}`.
    * </pre>
@@ -264,8 +264,8 @@ public interface StreamingPullRequestOrBuilder
    *
    *
    * <pre>
-   * Required. The ack deadline to use for the stream. This must be provided in the
-   * first request on the stream, but it can also be updated on subsequent
+   * Required. The ack deadline to use for the stream. This must be provided in
+   * the first request on the stream, but it can also be updated on subsequent
    * requests from client to server. The minimum deadline you can specify is 10
    * seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
    * </pre>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
index af7af8ecd..760cf6234 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
@@ -284,10 +284,9 @@ public com.google.protobuf.ByteString getNameBytes() {
    *
    *
    * <pre>
-   * Required. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`.
-   * The value of this field will be `_deleted-topic_` if the topic has been
-   * deleted.
+   * Required. The name of the topic from which this subscription is receiving
+   * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+   * field will be `_deleted-topic_` if the topic has been deleted.
    * </pre>
    *
    * <code>
@@ -311,10 +310,9 @@ public java.lang.String getTopic() {
    *
    *
    * <pre>
-   * Required. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`.
-   * The value of this field will be `_deleted-topic_` if the topic has been
-   * deleted.
+   * Required. The name of the topic from which this subscription is receiving
+   * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+   * field will be `_deleted-topic_` if the topic has been deleted.
    * </pre>
    *
    * <code>
@@ -1420,10 +1418,9 @@ public Builder setNameBytes(com.google.protobuf.ByteString value) {
      *
      *
      * <pre>
-     * Required. The name of the topic from which this subscription is receiving messages.
-     * Format is `projects/{project}/topics/{topic}`.
-     * The value of this field will be `_deleted-topic_` if the topic has been
-     * deleted.
+     * Required. The name of the topic from which this subscription is receiving
+     * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+     * field will be `_deleted-topic_` if the topic has been deleted.
      * </pre>
      *
      * <code>
@@ -1447,10 +1444,9 @@ public java.lang.String getTopic() {
      *
      *
      * <pre>
-     * Required. The name of the topic from which this subscription is receiving messages.
-     * Format is `projects/{project}/topics/{topic}`.
-     * The value of this field will be `_deleted-topic_` if the topic has been
-     * deleted.
+     * Required. The name of the topic from which this subscription is receiving
+     * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+     * field will be `_deleted-topic_` if the topic has been deleted.
      * </pre>
      *
      * <code>
@@ -1474,10 +1470,9 @@ public com.google.protobuf.ByteString getTopicBytes() {
      *
      *
      * <pre>
-     * Required. The name of the topic from which this subscription is receiving messages.
-     * Format is `projects/{project}/topics/{topic}`.
-     * The value of this field will be `_deleted-topic_` if the topic has been
-     * deleted.
+     * Required. The name of the topic from which this subscription is receiving
+     * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+     * field will be `_deleted-topic_` if the topic has been deleted.
      * </pre>
      *
      * <code>
@@ -1500,10 +1495,9 @@ public Builder setTopic(java.lang.String value) {
      *
      *
      * <pre>
-     * Required. The name of the topic from which this subscription is receiving messages.
-     * Format is `projects/{project}/topics/{topic}`.
-     * The value of this field will be `_deleted-topic_` if the topic has been
-     * deleted.
+     * Required. The name of the topic from which this subscription is receiving
+     * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+     * field will be `_deleted-topic_` if the topic has been deleted.
      * </pre>
      *
      * <code>
@@ -1522,10 +1516,9 @@ public Builder clearTopic() {
      *
      *
      * <pre>
-     * Required. The name of the topic from which this subscription is receiving messages.
-     * Format is `projects/{project}/topics/{topic}`.
-     * The value of this field will be `_deleted-topic_` if the topic has been
-     * deleted.
+     * Required. The name of the topic from which this subscription is receiving
+     * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+     * field will be `_deleted-topic_` if the topic has been deleted.
      * </pre>
      *
      * <code>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
index 840cd7f6a..acc4e7572 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
@@ -62,10 +62,9 @@ public interface SubscriptionOrBuilder
    *
    *
    * <pre>
-   * Required. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`.
-   * The value of this field will be `_deleted-topic_` if the topic has been
-   * deleted.
+   * Required. The name of the topic from which this subscription is receiving
+   * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+   * field will be `_deleted-topic_` if the topic has been deleted.
    * </pre>
    *
    * <code>
@@ -79,10 +78,9 @@ public interface SubscriptionOrBuilder
    *
    *
    * <pre>
-   * Required. The name of the topic from which this subscription is receiving messages.
-   * Format is `projects/{project}/topics/{topic}`.
-   * The value of this field will be `_deleted-topic_` if the topic has been
-   * deleted.
+   * Required. The name of the topic from which this subscription is receiving
+   * messages. Format is `projects/{project}/topics/{topic}`. The value of this
+   * field will be `_deleted-topic_` if the topic has been deleted.
    * </pre>
    *
    * <code>
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequest.java
index d4f95780f..5309c9bd7 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequest.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequest.java
@@ -180,8 +180,8 @@ public com.google.pubsub.v1.TopicOrBuilder getTopicOrBuilder() {
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
@@ -199,8 +199,8 @@ public boolean hasUpdateMask() {
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
@@ -218,8 +218,8 @@ public com.google.protobuf.FieldMask getUpdateMask() {
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
@@ -774,8 +774,8 @@ public com.google.pubsub.v1.TopicOrBuilder getTopicOrBuilder() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -793,8 +793,8 @@ public boolean hasUpdateMask() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -818,8 +818,8 @@ public com.google.protobuf.FieldMask getUpdateMask() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -845,8 +845,8 @@ public Builder setUpdateMask(com.google.protobuf.FieldMask value) {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -869,8 +869,8 @@ public Builder setUpdateMask(com.google.protobuf.FieldMask.Builder builderForVal
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -898,8 +898,8 @@ public Builder mergeUpdateMask(com.google.protobuf.FieldMask value) {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -923,8 +923,8 @@ public Builder clearUpdateMask() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -942,8 +942,8 @@ public com.google.protobuf.FieldMask.Builder getUpdateMaskBuilder() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
@@ -965,8 +965,8 @@ public com.google.protobuf.FieldMaskOrBuilder getUpdateMaskOrBuilder() {
      *
      *
      * <pre>
-     * Required. Indicates which fields in the provided topic to update. Must be specified
-     * and non-empty. Note that if `update_mask` contains
+     * Required. Indicates which fields in the provided topic to update. Must be
+     * specified and non-empty. Note that if `update_mask` contains
      * "message_storage_policy" then the new value will be determined based on the
      * policy configured at the project or organization level. The
      * `message_storage_policy` must not be set in the `topic` provided above.
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
index 6cf4e911a..257f0fdb8 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
@@ -62,8 +62,8 @@ public interface UpdateTopicRequestOrBuilder
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
@@ -79,8 +79,8 @@ public interface UpdateTopicRequestOrBuilder
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
@@ -96,8 +96,8 @@ public interface UpdateTopicRequestOrBuilder
    *
    *
    * <pre>
-   * Required. Indicates which fields in the provided topic to update. Must be specified
-   * and non-empty. Note that if `update_mask` contains
+   * Required. Indicates which fields in the provided topic to update. Must be
+   * specified and non-empty. Note that if `update_mask` contains
    * "message_storage_policy" then the new value will be determined based on the
    * policy configured at the project or organization level. The
    * `message_storage_policy` must not be set in the `topic` provided above.
diff --git a/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto b/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
index adaf8c6fc..55cfa531f 100644
--- a/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
+++ b/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
@@ -16,6 +16,7 @@ syntax = "proto3";
 
 package google.pubsub.v1;
 
+import "google/api/annotations.proto";
 import "google/api/client.proto";
 import "google/api/field_behavior.proto";
 import "google/api/resource.proto";
@@ -23,7 +24,6 @@ import "google/protobuf/duration.proto";
 import "google/protobuf/empty.proto";
 import "google/protobuf/field_mask.proto";
 import "google/protobuf/timestamp.proto";
-import "google/api/annotations.proto";
 
 option cc_enable_arenas = true;
 option csharp_namespace = "Google.Cloud.PubSub.V1";
@@ -89,7 +89,8 @@ service Publisher {
   }
 
   // Lists the names of the subscriptions on this topic.
-  rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest) returns (ListTopicSubscriptionsResponse) {
+  rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest)
+      returns (ListTopicSubscriptionsResponse) {
     option (google.api.http) = {
       get: "/v1/{topic=projects/*/topics/*}/subscriptions"
     };
@@ -102,10 +103,12 @@ service Publisher {
   // you to manage message acknowledgments in bulk. That is, you can set the
   // acknowledgment state of messages in an existing subscription to the state
   // captured by a snapshot.
-  rpc ListTopicSnapshots(ListTopicSnapshotsRequest) returns (ListTopicSnapshotsResponse) {
+  rpc ListTopicSnapshots(ListTopicSnapshotsRequest)
+      returns (ListTopicSnapshotsResponse) {
     option (google.api.http) = {
       get: "/v1/{topic=projects/*/topics/*}/snapshots"
     };
+    option (google.api.method_signature) = "topic";
   }
 
   // Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -208,9 +211,7 @@ message GetTopicRequest {
   // Format is `projects/{project}/topics/{topic}`.
   string topic = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Topic"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
   ];
 }
 
@@ -219,12 +220,13 @@ message UpdateTopicRequest {
   // Required. The updated topic object.
   Topic topic = 1 [(google.api.field_behavior) = REQUIRED];
 
-  // Required. Indicates which fields in the provided topic to update. Must be specified
-  // and non-empty. Note that if `update_mask` contains
+  // Required. Indicates which fields in the provided topic to update. Must be
+  // specified and non-empty. Note that if `update_mask` contains
   // "message_storage_policy" then the new value will be determined based on the
   // policy configured at the project or organization level. The
   // `message_storage_policy` must not be set in the `topic` provided above.
-  google.protobuf.FieldMask update_mask = 2 [(google.api.field_behavior) = REQUIRED];
+  google.protobuf.FieldMask update_mask = 2
+      [(google.api.field_behavior) = REQUIRED];
 }
 
 // Request for the Publish method.
@@ -233,9 +235,7 @@ message PublishRequest {
   // Format is `projects/{project}/topics/{topic}`.
   string topic = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Topic"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
   ];
 
   // Required. The messages to publish.
@@ -286,9 +286,7 @@ message ListTopicSubscriptionsRequest {
   // Format is `projects/{project}/topics/{topic}`.
   string topic = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Topic"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
   ];
 
   // Maximum number of subscription names to return.
@@ -304,8 +302,8 @@ message ListTopicSubscriptionsRequest {
 message ListTopicSubscriptionsResponse {
   // The names of the subscriptions that match the request.
   repeated string subscriptions = 1 [(google.api.resource_reference) = {
-                                       type: "pubsub.googleapis.com/Subscription"
-                                     }];
+    type: "pubsub.googleapis.com/Subscription"
+  }];
 
   // If not empty, indicates that there may be more subscriptions that match
   // the request; this value should be passed in a new
@@ -315,9 +313,12 @@ message ListTopicSubscriptionsResponse {
 
 // Request for the `ListTopicSnapshots` method.
 message ListTopicSnapshotsRequest {
-  // The name of the topic that snapshots are attached to.
+  // Required. The name of the topic that snapshots are attached to.
   // Format is `projects/{project}/topics/{topic}`.
-  string topic = 1;
+  string topic = 1 [
+    (google.api.field_behavior) = REQUIRED,
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
+  ];
 
   // Maximum number of snapshot names to return.
   int32 page_size = 2;
@@ -345,9 +346,7 @@ message DeleteTopicRequest {
   // Format is `projects/{project}/topics/{topic}`.
   string topic = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Topic"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
   ];
 }
 
@@ -378,7 +377,8 @@ service Subscriber {
       put: "/v1/{name=projects/*/subscriptions/*}"
       body: "*"
     };
-    option (google.api.method_signature) = "name,topic,push_config,ack_deadline_seconds";
+    option (google.api.method_signature) =
+        "name,topic,push_config,ack_deadline_seconds";
   }
 
   // Gets the configuration details of a subscription.
@@ -399,7 +399,8 @@ service Subscriber {
   }
 
   // Lists matching subscriptions.
-  rpc ListSubscriptions(ListSubscriptionsRequest) returns (ListSubscriptionsResponse) {
+  rpc ListSubscriptions(ListSubscriptionsRequest)
+      returns (ListSubscriptionsResponse) {
     option (google.api.http) = {
       get: "/v1/{project=projects/*}/subscriptions"
     };
@@ -411,7 +412,8 @@ service Subscriber {
   // `NOT_FOUND`. After a subscription is deleted, a new one may be created with
   // the same name, but the new one has no association with the old
   // subscription or its topic unless the same topic is specified.
-  rpc DeleteSubscription(DeleteSubscriptionRequest) returns (google.protobuf.Empty) {
+  rpc DeleteSubscription(DeleteSubscriptionRequest)
+      returns (google.protobuf.Empty) {
     option (google.api.http) = {
       delete: "/v1/{subscription=projects/*/subscriptions/*}"
     };
@@ -423,12 +425,14 @@ service Subscriber {
   // subscriber, or to make the message available for redelivery if the
   // processing was interrupted. Note that this does not modify the
   // subscription-level `ackDeadlineSeconds` used for subsequent messages.
-  rpc ModifyAckDeadline(ModifyAckDeadlineRequest) returns (google.protobuf.Empty) {
+  rpc ModifyAckDeadline(ModifyAckDeadlineRequest)
+      returns (google.protobuf.Empty) {
     option (google.api.http) = {
       post: "/v1/{subscription=projects/*/subscriptions/*}:modifyAckDeadline"
       body: "*"
     };
-    option (google.api.method_signature) = "subscription,ack_ids,ack_deadline_seconds";
+    option (google.api.method_signature) =
+        "subscription,ack_ids,ack_deadline_seconds";
   }
 
   // Acknowledges the messages associated with the `ack_ids` in the
@@ -454,7 +458,8 @@ service Subscriber {
       post: "/v1/{subscription=projects/*/subscriptions/*}:pull"
       body: "*"
     };
-    option (google.api.method_signature) = "subscription,return_immediately,max_messages";
+    option (google.api.method_signature) =
+        "subscription,return_immediately,max_messages";
   }
 
   // Establishes a stream with the server, which sends messages down to the
@@ -464,8 +469,8 @@ service Subscriber {
   // reassign server-side resources, in which case, the client should
   // re-establish the stream. Flow control can be achieved by configuring the
   // underlying RPC channel.
-  rpc StreamingPull(stream StreamingPullRequest) returns (stream StreamingPullResponse) {
-  }
+  rpc StreamingPull(stream StreamingPullRequest)
+      returns (stream StreamingPullResponse) {}
 
   // Modifies the `PushConfig` for a specified subscription.
   //
@@ -473,7 +478,8 @@ service Subscriber {
   // an empty `PushConfig`) or vice versa, or change the endpoint URL and other
   // attributes of a push subscription. Messages will accumulate for delivery
   // continuously through the call regardless of changes to the `PushConfig`.
-  rpc ModifyPushConfig(ModifyPushConfigRequest) returns (google.protobuf.Empty) {
+  rpc ModifyPushConfig(ModifyPushConfigRequest)
+      returns (google.protobuf.Empty) {
     option (google.api.http) = {
       post: "/v1/{subscription=projects/*/subscriptions/*}:modifyPushConfig"
       body: "*"
@@ -490,6 +496,7 @@ service Subscriber {
     option (google.api.http) = {
       get: "/v1/{snapshot=projects/*/snapshots/*}"
     };
+    option (google.api.method_signature) = "snapshot";
   }
 
   // Lists the existing snapshots. Snapshots are used in
@@ -592,15 +599,12 @@ message Subscription {
   // in length, and it must not start with `"goog"`.
   string name = 1 [(google.api.field_behavior) = REQUIRED];
 
-  // Required. The name of the topic from which this subscription is receiving messages.
-  // Format is `projects/{project}/topics/{topic}`.
-  // The value of this field will be `_deleted-topic_` if the topic has been
-  // deleted.
+  // Required. The name of the topic from which this subscription is receiving
+  // messages. Format is `projects/{project}/topics/{topic}`. The value of this
+  // field will be `_deleted-topic_` if the topic has been deleted.
   string topic = 2 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Topic"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
   ];
 
   // If push delivery is used with this subscription, this field is
@@ -834,7 +838,8 @@ message UpdateSubscriptionRequest {
 
   // Required. Indicates which fields in the provided subscription to update.
   // Must be specified and non-empty.
-  google.protobuf.FieldMask update_mask = 2 [(google.api.field_behavior) = REQUIRED];
+  google.protobuf.FieldMask update_mask = 2
+      [(google.api.field_behavior) = REQUIRED];
 }
 
 // Request for the `ListSubscriptions` method.
@@ -911,14 +916,18 @@ message PullRequest {
     }
   ];
 
-  // If this field set to true, the system will respond immediately even if
-  // it there are no messages available to return in the `Pull` response.
-  // Otherwise, the system may wait (for a bounded amount of time) until at
-  // least one message is available, rather than returning no messages.
-  bool return_immediately = 2;
-
-  // Required. The maximum number of messages to return for this request. Must be a
-  // positive integer. The Pub/Sub system may return fewer than the number
+  // Optional. If this field set to true, the system will respond immediately
+  // even if it there are no messages available to return in the `Pull`
+  // response. Otherwise, the system may wait (for a bounded amount of time)
+  // until at least one message is available, rather than returning no messages.
+  // Warning: setting this field to `true` is discouraged because it adversely
+  // impacts the performance of `Pull` operations. We recommend that users do
+  // not set this field.
+  bool return_immediately = 2
+      [deprecated = true, (google.api.field_behavior) = OPTIONAL];
+
+  // Required. The maximum number of messages to return for this request. Must
+  // be a positive integer. The Pub/Sub system may return fewer than the number
   // specified.
   int32 max_messages = 3 [(google.api.field_behavior) = REQUIRED];
 }
@@ -946,10 +955,10 @@ message ModifyAckDeadlineRequest {
   // Required. List of acknowledgment IDs.
   repeated string ack_ids = 4 [(google.api.field_behavior) = REQUIRED];
 
-  // Required. The new ack deadline with respect to the time this request was sent to
-  // the Pub/Sub system. For example, if the value is 10, the new
-  // ack deadline will expire 10 seconds after the `ModifyAckDeadline` call
-  // was made. Specifying zero might immediately make the message available for
+  // Required. The new ack deadline with respect to the time this request was
+  // sent to the Pub/Sub system. For example, if the value is 10, the new ack
+  // deadline will expire 10 seconds after the `ModifyAckDeadline` call was
+  // made. Specifying zero might immediately make the message available for
   // delivery to another subscriber client. This typically results in an
   // increase in the rate of message redeliveries (that is, duplicates).
   // The minimum deadline you can specify is 0 seconds.
@@ -968,8 +977,9 @@ message AcknowledgeRequest {
     }
   ];
 
-  // Required. The acknowledgment ID for the messages being acknowledged that was returned
-  // by the Pub/Sub system in the `Pull` response. Must not be empty.
+  // Required. The acknowledgment ID for the messages being acknowledged that
+  // was returned by the Pub/Sub system in the `Pull` response. Must not be
+  // empty.
   repeated string ack_ids = 2 [(google.api.field_behavior) = REQUIRED];
 }
 
@@ -977,8 +987,8 @@ message AcknowledgeRequest {
 // establish the initial stream as well as to stream acknowledgements and ack
 // deadline modifications from the client to the server.
 message StreamingPullRequest {
-  // Required. The subscription for which to initialize the new stream. This must be
-  // provided in the first request on the stream, and must not be set in
+  // Required. The subscription for which to initialize the new stream. This
+  // must be provided in the first request on the stream, and must not be set in
   // subsequent requests from client to server.
   // Format is `projects/{project}/subscriptions/{sub}`.
   string subscription = 1 [
@@ -1015,11 +1025,12 @@ message StreamingPullRequest {
   // processing was interrupted.
   repeated string modify_deadline_ack_ids = 4;
 
-  // Required. The ack deadline to use for the stream. This must be provided in the
-  // first request on the stream, but it can also be updated on subsequent
+  // Required. The ack deadline to use for the stream. This must be provided in
+  // the first request on the stream, but it can also be updated on subsequent
   // requests from client to server. The minimum deadline you can specify is 10
   // seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
-  int32 stream_ack_deadline_seconds = 5 [(google.api.field_behavior) = REQUIRED];
+  int32 stream_ack_deadline_seconds = 5
+      [(google.api.field_behavior) = REQUIRED];
 
   // A unique identifier that is used to distinguish client instances from each
   // other. Only needs to be provided on the initial request. When a stream
@@ -1039,17 +1050,15 @@ message StreamingPullResponse {
 
 // Request for the `CreateSnapshot` method.
 message CreateSnapshotRequest {
-  // Required. User-provided name for this snapshot. If the name is not provided in the
-  // request, the server will assign a random name for this snapshot on the same
-  // project as the subscription. Note that for REST API requests, you must
-  // specify a name.  See the <a
+  // Required. User-provided name for this snapshot. If the name is not provided
+  // in the request, the server will assign a random name for this snapshot on
+  // the same project as the subscription. Note that for REST API requests, you
+  // must specify a name.  See the <a
   // href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
   // name rules</a>. Format is `projects/{project}/snapshots/{snap}`.
   string name = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Snapshot"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Snapshot" }
   ];
 
   // Required. The subscription whose backlog the snapshot retains.
@@ -1080,7 +1089,8 @@ message UpdateSnapshotRequest {
 
   // Required. Indicates which fields in the provided snapshot to update.
   // Must be specified and non-empty.
-  google.protobuf.FieldMask update_mask = 2 [(google.api.field_behavior) = REQUIRED];
+  google.protobuf.FieldMask update_mask = 2
+      [(google.api.field_behavior) = REQUIRED];
 }
 
 // A snapshot resource. Snapshots are used in
@@ -1099,9 +1109,9 @@ message Snapshot {
   string name = 1;
 
   // The name of the topic from which this snapshot is retaining messages.
-  string topic = 2 [(google.api.resource_reference) = {
-                      type: "pubsub.googleapis.com/Topic"
-                    }];
+  string topic = 2 [
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Topic" }
+  ];
 
   // The snapshot is guaranteed to exist up until this time.
   // A newly-created snapshot expires no later than 7 days from the time of its
@@ -1126,9 +1136,7 @@ message GetSnapshotRequest {
   // Format is `projects/{project}/snapshots/{snap}`.
   string snapshot = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Snapshot"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Snapshot" }
   ];
 }
 
@@ -1168,9 +1176,7 @@ message DeleteSnapshotRequest {
   // Format is `projects/{project}/snapshots/{snap}`.
   string snapshot = 1 [
     (google.api.field_behavior) = REQUIRED,
-    (google.api.resource_reference) = {
-      type: "pubsub.googleapis.com/Snapshot"
-    }
+    (google.api.resource_reference) = { type: "pubsub.googleapis.com/Snapshot" }
   ];
 }
 
@@ -1202,12 +1208,10 @@ message SeekRequest {
     // the provided subscription.
     // Format is `projects/{project}/snapshots/{snap}`.
     string snapshot = 3 [(google.api.resource_reference) = {
-                           type: "pubsub.googleapis.com/Snapshot"
-                         }];
+      type: "pubsub.googleapis.com/Snapshot"
+    }];
   }
 }
 
 // Response for the `Seek` method (this response is empty).
-message SeekResponse {
-
-}
+message SeekResponse {}
diff --git a/synth.metadata b/synth.metadata
index 4c204715a..a8cfb72d0 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -1,20 +1,20 @@
 {
-  "updateTime": "2020-03-02T23:00:50.055052Z",
+  "updateTime": "2020-03-09T22:03:30.134601Z",
   "sources": [
     {
       "generator": {
         "name": "artman",
-        "version": "0.47.0",
-        "dockerImage": "googleapis/artman@sha256:b3e50d6b8de03920b9f065bbc3d210e2ca93a043446f1fa16cdf567393c09678"
+        "version": "1.0.0",
+        "dockerImage": "googleapis/artman@sha256:f37f2464788cb551299209b4fcab4eb323533154488c2ef9ec0c75d7c2b4b482"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "244ab2b83a82076a1fa7be63b7e0671af73f5c02",
-        "internalRef": "298455048",
-        "log": "244ab2b83a82076a1fa7be63b7e0671af73f5c02\nAdds service config definition for bigqueryreservation v1\n\nPiperOrigin-RevId: 298455048\n\n83c6f84035ee0f80eaa44d8b688a010461cc4080\nUpdate google/api/auth.proto to make AuthProvider to have JwtLocation\n\nPiperOrigin-RevId: 297918498\n\ne9e90a787703ec5d388902e2cb796aaed3a385b4\nDialogflow weekly v2/v2beta1 library update:\n  - adding get validation result\n  - adding field mask override control for output audio config\nImportant updates are also posted at:\nhttps://cloud.google.com/dialogflow/docs/release-notes\n\nPiperOrigin-RevId: 297671458\n\n"
+        "sha": "29a47c965aac79e3fe8e3314482ca0b5967680f0",
+        "internalRef": "299917154",
+        "log": "29a47c965aac79e3fe8e3314482ca0b5967680f0\nIncrease timeout to 1hr for method `dropRange` in bigtable/admin/v2, which is\nsynced with the timeout setting in gapic_yaml.\n\nPiperOrigin-RevId: 299917154\n\n8f631c4c70a60a9c7da3749511ee4ad432b62898\nbuild(google/maps/roads/v1op): move go to monorepo pattern\n\nPiperOrigin-RevId: 299885195\n\nd66816518844ebbf63504c9e8dfc7133921dd2cd\nbuild(google/maps/roads/v1op): Add bazel build files to generate clients.\n\nPiperOrigin-RevId: 299851148\n\naf7dff701fabe029672168649c62356cf1bb43d0\nAdd LogPlayerReports and LogImpressions to Playable Locations service\n\nPiperOrigin-RevId: 299724050\n\nb6927fca808f38df32a642c560082f5bf6538ced\nUpdate BigQuery Connection API v1beta1 proto: added credential to CloudSqlProperties.\n\nPiperOrigin-RevId: 299503150\n\n91e1fb5ef9829c0c7a64bfa5bde330e6ed594378\nchore: update protobuf (protoc) version to 3.11.2\n\nPiperOrigin-RevId: 299404145\n\n30e36b4bee6749c4799f4fc1a51cc8f058ba167d\nUpdate cloud asset api v1p4beta1.\n\nPiperOrigin-RevId: 299399890\n\nffbb493674099f265693872ae250711b2238090c\nfeat: cloudbuild/v1 add new fields and annotate OUTPUT_OUT fields.\n\nPiperOrigin-RevId: 299397780\n\nbc973a15818e00c19e121959832676e9b7607456\nbazel: Fix broken common  dependency\n\nPiperOrigin-RevId: 299397431\n\n71094a343e3b962e744aa49eb9338219537474e4\nchore: bigtable/admin/v2 publish retry config\n\nPiperOrigin-RevId: 299391875\n\n8f488efd7bda33885cb674ddd023b3678c40bd82\nfeat: Migrate logging to GAPIC v2; release new features.\n\nIMPORTANT: This is a breaking change for client libraries\nin all languages.\n\nCommitter: @lukesneeringer, @jskeet\nPiperOrigin-RevId: 299370279\n\n007605bf9ad3a1fd775014ebefbf7f1e6b31ee71\nUpdate API for bigqueryreservation v1beta1.\n- Adds flex capacity commitment plan to CapacityCommitment.\n- Adds methods for getting and updating BiReservations.\n- Adds methods for updating/splitting/merging CapacityCommitments.\n\nPiperOrigin-RevId: 299368059\n\nf0b581b5bdf803e45201ecdb3688b60e381628a8\nfix: recommendationengine/v1beta1 update some comments\n\nPiperOrigin-RevId: 299181282\n\n10e9a0a833dc85ff8f05b2c67ebe5ac785fe04ff\nbuild: add generated BUILD file for Routes Preferred API\n\nPiperOrigin-RevId: 299164808\n\n86738c956a8238d7c77f729be78b0ed887a6c913\npublish v1p1beta1: update with absolute address in comments\n\nPiperOrigin-RevId: 299152383\n\n73d9f2ad4591de45c2e1f352bc99d70cbd2a6d95\npublish v1: update with absolute address in comments\n\nPiperOrigin-RevId: 299147194\n\nd2158f24cb77b0b0ccfe68af784c6a628705e3c6\npublish v1beta2: update with absolute address in comments\n\nPiperOrigin-RevId: 299147086\n\n7fca61292c11b4cd5b352cee1a50bf88819dd63b\npublish v1p2beta1: update with absolute address in comments\n\nPiperOrigin-RevId: 299146903\n\n583b7321624736e2c490e328f4b1957335779295\npublish v1p3beta1: update with absolute address in comments\n\nPiperOrigin-RevId: 299146674\n\n638253bf86d1ce1c314108a089b7351440c2f0bf\nfix: add java_multiple_files option for automl text_sentiment.proto\n\nPiperOrigin-RevId: 298971070\n\n373d655703bf914fb8b0b1cc4071d772bac0e0d1\nUpdate Recs AI Beta public bazel file\n\nPiperOrigin-RevId: 298961623\n\ndcc5d00fc8a8d8b56f16194d7c682027b2c66a3b\nfix: add java_multiple_files option for automl classification.proto\n\nPiperOrigin-RevId: 298953301\n\na3f791827266f3496a6a5201d58adc4bb265c2a3\nchore: automl/v1 publish annotations and retry config\n\nPiperOrigin-RevId: 298942178\n\n01c681586d8d6dbd60155289b587aee678530bd9\nMark return_immediately in PullRequest deprecated.\n\nPiperOrigin-RevId: 298893281\n\nc9f5e9c4bfed54bbd09227e990e7bded5f90f31c\nRemove out of date documentation for predicate support on the Storage API\n\nPiperOrigin-RevId: 298883309\n\nfd5b3b8238d783b04692a113ffe07c0363f5de0f\ngenerate webrisk v1 proto\n\nPiperOrigin-RevId: 298847934\n\n541b1ded4abadcc38e8178680b0677f65594ea6f\nUpdate cloud asset api v1p4beta1.\n\nPiperOrigin-RevId: 298686266\n\nc0d171acecb4f5b0bfd2c4ca34fc54716574e300\n  Updated to include the Notification v1 API.\n\nPiperOrigin-RevId: 298652775\n\n2346a9186c0bff2c9cc439f2459d558068637e05\nAdd Service Directory v1beta1 protos and configs\n\nPiperOrigin-RevId: 298625638\n\na78ed801b82a5c6d9c5368e24b1412212e541bb7\nPublishing v3 protos and configs.\n\nPiperOrigin-RevId: 298607357\n\n4a180bfff8a21645b3a935c2756e8d6ab18a74e0\nautoml/v1beta1 publish proto updates\n\nPiperOrigin-RevId: 298484782\n\n6de6e938b7df1cd62396563a067334abeedb9676\nchore: use the latest gapic-generator and protoc-java-resource-name-plugin in Bazel workspace.\n\nPiperOrigin-RevId: 298474513\n\n"
       }
     },
     {