diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfig.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfig.java
index 4f98b34b1..f847f91d6 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfig.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfig.java
@@ -130,6 +130,17 @@ public enum State implements com.google.protobuf.ProtocolMessageEnum {
      * <code>IN_TRANSIT_LOCATION_RESTRICTION = 4;</code>
      */
     IN_TRANSIT_LOCATION_RESTRICTION(4),
+    /**
+     *
+     *
+     * <pre>
+     * Cannot write to the Cloud Storage bucket due to an incompatibility
+     * between the topic schema and subscription settings.
+     * </pre>
+     *
+     * <code>SCHEMA_MISMATCH = 5;</code>
+     */
+    SCHEMA_MISMATCH(5),
     UNRECOGNIZED(-1),
     ;
 
@@ -185,6 +196,17 @@ public enum State implements com.google.protobuf.ProtocolMessageEnum {
      * <code>IN_TRANSIT_LOCATION_RESTRICTION = 4;</code>
      */
     public static final int IN_TRANSIT_LOCATION_RESTRICTION_VALUE = 4;
+    /**
+     *
+     *
+     * <pre>
+     * Cannot write to the Cloud Storage bucket due to an incompatibility
+     * between the topic schema and subscription settings.
+     * </pre>
+     *
+     * <code>SCHEMA_MISMATCH = 5;</code>
+     */
+    public static final int SCHEMA_MISMATCH_VALUE = 5;
 
     public final int getNumber() {
       if (this == UNRECOGNIZED) {
@@ -220,6 +242,8 @@ public static State forNumber(int value) {
           return NOT_FOUND;
         case 4:
           return IN_TRANSIT_LOCATION_RESTRICTION;
+        case 5:
+          return SCHEMA_MISMATCH;
         default:
           return null;
       }
@@ -721,6 +745,20 @@ public interface AvroConfigOrBuilder
      * @return The writeMetadata.
      */
     boolean getWriteMetadata();
+
+    /**
+     *
+     *
+     * <pre>
+     * Optional. When true, the output Cloud Storage file will be serialized
+     * using the topic schema, if it exists.
+     * </pre>
+     *
+     * <code>bool use_topic_schema = 2 [(.google.api.field_behavior) = OPTIONAL];</code>
+     *
+     * @return The useTopicSchema.
+     */
+    boolean getUseTopicSchema();
   }
   /**
    *
@@ -788,6 +826,25 @@ public boolean getWriteMetadata() {
       return writeMetadata_;
     }
 
+    public static final int USE_TOPIC_SCHEMA_FIELD_NUMBER = 2;
+    private boolean useTopicSchema_ = false;
+    /**
+     *
+     *
+     * <pre>
+     * Optional. When true, the output Cloud Storage file will be serialized
+     * using the topic schema, if it exists.
+     * </pre>
+     *
+     * <code>bool use_topic_schema = 2 [(.google.api.field_behavior) = OPTIONAL];</code>
+     *
+     * @return The useTopicSchema.
+     */
+    @java.lang.Override
+    public boolean getUseTopicSchema() {
+      return useTopicSchema_;
+    }
+
     private byte memoizedIsInitialized = -1;
 
     @java.lang.Override
@@ -805,6 +862,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
       if (writeMetadata_ != false) {
         output.writeBool(1, writeMetadata_);
       }
+      if (useTopicSchema_ != false) {
+        output.writeBool(2, useTopicSchema_);
+      }
       getUnknownFields().writeTo(output);
     }
 
@@ -817,6 +877,9 @@ public int getSerializedSize() {
       if (writeMetadata_ != false) {
         size += com.google.protobuf.CodedOutputStream.computeBoolSize(1, writeMetadata_);
       }
+      if (useTopicSchema_ != false) {
+        size += com.google.protobuf.CodedOutputStream.computeBoolSize(2, useTopicSchema_);
+      }
       size += getUnknownFields().getSerializedSize();
       memoizedSize = size;
       return size;
@@ -834,6 +897,7 @@ public boolean equals(final java.lang.Object obj) {
           (com.google.pubsub.v1.CloudStorageConfig.AvroConfig) obj;
 
       if (getWriteMetadata() != other.getWriteMetadata()) return false;
+      if (getUseTopicSchema() != other.getUseTopicSchema()) return false;
       if (!getUnknownFields().equals(other.getUnknownFields())) return false;
       return true;
     }
@@ -847,6 +911,8 @@ public int hashCode() {
       hash = (19 * hash) + getDescriptor().hashCode();
       hash = (37 * hash) + WRITE_METADATA_FIELD_NUMBER;
       hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getWriteMetadata());
+      hash = (37 * hash) + USE_TOPIC_SCHEMA_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getUseTopicSchema());
       hash = (29 * hash) + getUnknownFields().hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -990,6 +1056,7 @@ public Builder clear() {
         super.clear();
         bitField0_ = 0;
         writeMetadata_ = false;
+        useTopicSchema_ = false;
         return this;
       }
 
@@ -1029,6 +1096,9 @@ private void buildPartial0(com.google.pubsub.v1.CloudStorageConfig.AvroConfig re
         if (((from_bitField0_ & 0x00000001) != 0)) {
           result.writeMetadata_ = writeMetadata_;
         }
+        if (((from_bitField0_ & 0x00000002) != 0)) {
+          result.useTopicSchema_ = useTopicSchema_;
+        }
       }
 
       @java.lang.Override
@@ -1082,6 +1152,9 @@ public Builder mergeFrom(com.google.pubsub.v1.CloudStorageConfig.AvroConfig othe
         if (other.getWriteMetadata() != false) {
           setWriteMetadata(other.getWriteMetadata());
         }
+        if (other.getUseTopicSchema() != false) {
+          setUseTopicSchema(other.getUseTopicSchema());
+        }
         this.mergeUnknownFields(other.getUnknownFields());
         onChanged();
         return this;
@@ -1114,6 +1187,12 @@ public Builder mergeFrom(
                   bitField0_ |= 0x00000001;
                   break;
                 } // case 8
+              case 16:
+                {
+                  useTopicSchema_ = input.readBool();
+                  bitField0_ |= 0x00000002;
+                  break;
+                } // case 16
               default:
                 {
                   if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -1201,6 +1280,62 @@ public Builder clearWriteMetadata() {
         return this;
       }
 
+      private boolean useTopicSchema_;
+      /**
+       *
+       *
+       * <pre>
+       * Optional. When true, the output Cloud Storage file will be serialized
+       * using the topic schema, if it exists.
+       * </pre>
+       *
+       * <code>bool use_topic_schema = 2 [(.google.api.field_behavior) = OPTIONAL];</code>
+       *
+       * @return The useTopicSchema.
+       */
+      @java.lang.Override
+      public boolean getUseTopicSchema() {
+        return useTopicSchema_;
+      }
+      /**
+       *
+       *
+       * <pre>
+       * Optional. When true, the output Cloud Storage file will be serialized
+       * using the topic schema, if it exists.
+       * </pre>
+       *
+       * <code>bool use_topic_schema = 2 [(.google.api.field_behavior) = OPTIONAL];</code>
+       *
+       * @param value The useTopicSchema to set.
+       * @return This builder for chaining.
+       */
+      public Builder setUseTopicSchema(boolean value) {
+
+        useTopicSchema_ = value;
+        bitField0_ |= 0x00000002;
+        onChanged();
+        return this;
+      }
+      /**
+       *
+       *
+       * <pre>
+       * Optional. When true, the output Cloud Storage file will be serialized
+       * using the topic schema, if it exists.
+       * </pre>
+       *
+       * <code>bool use_topic_schema = 2 [(.google.api.field_behavior) = OPTIONAL];</code>
+       *
+       * @return This builder for chaining.
+       */
+      public Builder clearUseTopicSchema() {
+        bitField0_ = (bitField0_ & ~0x00000002);
+        useTopicSchema_ = false;
+        onChanged();
+        return this;
+      }
+
       @java.lang.Override
       public final Builder setUnknownFields(
           final com.google.protobuf.UnknownFieldSet unknownFields) {
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 4ef81ddb7..a80aaa209 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
@@ -427,7 +427,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "\tB\003\340A\001\"\212\001\n\005State\022\025\n\021STATE_UNSPECIFIED\020\000\022"
           + "\n\n\006ACTIVE\020\001\022\025\n\021PERMISSION_DENIED\020\002\022\r\n\tNO"
           + "T_FOUND\020\003\022\023\n\017SCHEMA_MISMATCH\020\004\022#\n\037IN_TRA"
-          + "NSIT_LOCATION_RESTRICTION\020\005\"\231\005\n\022CloudSto"
+          + "NSIT_LOCATION_RESTRICTION\020\005\"\316\005\n\022CloudSto"
           + "rageConfig\022\023\n\006bucket\030\001 \001(\tB\003\340A\002\022\034\n\017filen"
           + "ame_prefix\030\002 \001(\tB\003\340A\001\022\034\n\017filename_suffix"
           + "\030\003 \001(\tB\003\340A\001\022%\n\030filename_datetime_format\030"
@@ -439,219 +439,220 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "obuf.DurationB\003\340A\001\022\026\n\tmax_bytes\030\007 \001(\003B\003\340"
           + "A\001\022>\n\005state\030\t \001(\0162*.google.pubsub.v1.Clo"
           + "udStorageConfig.StateB\003\340A\003\022\"\n\025service_ac"
-          + "count_email\030\013 \001(\tB\003\340A\001\032\014\n\nTextConfig\032)\n\n"
-          + "AvroConfig\022\033\n\016write_metadata\030\001 \001(\010B\003\340A\001\""
-          + "u\n\005State\022\025\n\021STATE_UNSPECIFIED\020\000\022\n\n\006ACTIV"
-          + "E\020\001\022\025\n\021PERMISSION_DENIED\020\002\022\r\n\tNOT_FOUND\020"
-          + "\003\022#\n\037IN_TRANSIT_LOCATION_RESTRICTION\020\004B\017"
-          + "\n\routput_format\"|\n\017ReceivedMessage\022\023\n\006ac"
-          + "k_id\030\001 \001(\tB\003\340A\001\0225\n\007message\030\002 \001(\0132\037.googl"
-          + "e.pubsub.v1.PubsubMessageB\003\340A\001\022\035\n\020delive"
-          + "ry_attempt\030\003 \001(\005B\003\340A\001\"Z\n\026GetSubscription"
-          + "Request\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"p"
-          + "ubsub.googleapis.com/Subscription\"\214\001\n\031Up"
-          + "dateSubscriptionRequest\0229\n\014subscription\030"
-          + "\001 \001(\0132\036.google.pubsub.v1.SubscriptionB\003\340"
-          + "A\002\0224\n\013update_mask\030\002 \001(\0132\032.google.protobu"
-          + "f.FieldMaskB\003\340A\002\"\221\001\n\030ListSubscriptionsRe"
-          + "quest\022D\n\007project\030\001 \001(\tB3\340A\002\372A-\n+cloudres"
-          + "ourcemanager.googleapis.com/Project\022\026\n\tp"
-          + "age_size\030\002 \001(\005B\003\340A\001\022\027\n\npage_token\030\003 \001(\tB"
-          + "\003\340A\001\"u\n\031ListSubscriptionsResponse\022:\n\rsub"
-          + "scriptions\030\001 \003(\0132\036.google.pubsub.v1.Subs"
-          + "criptionB\003\340A\001\022\034\n\017next_page_token\030\002 \001(\tB\003"
-          + "\340A\001\"]\n\031DeleteSubscriptionRequest\022@\n\014subs"
-          + "cription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapi"
-          + "s.com/Subscription\"\223\001\n\027ModifyPushConfigR"
-          + "equest\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pu"
-          + "bsub.googleapis.com/Subscription\0226\n\013push"
-          + "_config\030\002 \001(\0132\034.google.pubsub.v1.PushCon"
-          + "figB\003\340A\002\"\215\001\n\013PullRequest\022@\n\014subscription"
-          + "\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Su"
-          + "bscription\022!\n\022return_immediately\030\002 \001(\010B\005"
-          + "\030\001\340A\001\022\031\n\014max_messages\030\003 \001(\005B\003\340A\002\"Q\n\014Pull"
-          + "Response\022A\n\021received_messages\030\001 \003(\0132!.go"
-          + "ogle.pubsub.v1.ReceivedMessageB\003\340A\001\"\225\001\n\030"
-          + "ModifyAckDeadlineRequest\022@\n\014subscription"
-          + "\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Su"
-          + "bscription\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\022Acknowled"
-          + "geRequest\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n"
-          + "\"pubsub.googleapis.com/Subscription\022\024\n\007a"
-          + "ck_ids\030\002 \003(\tB\003\340A\002\"\307\002\n\024StreamingPullReque"
-          + "st\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\001\022$\n\027modify_deadline_seconds\030\003 "
-          + "\003(\005B\003\340A\001\022$\n\027modify_deadline_ack_ids\030\004 \003("
-          + "\tB\003\340A\001\022(\n\033stream_ack_deadline_seconds\030\005 "
-          + "\001(\005B\003\340A\002\022\026\n\tclient_id\030\006 \001(\tB\003\340A\001\022%\n\030max_"
-          + "outstanding_messages\030\007 \001(\003B\003\340A\001\022\"\n\025max_o"
-          + "utstanding_bytes\030\010 \001(\003B\003\340A\001\"\236\006\n\025Streamin"
-          + "gPullResponse\022A\n\021received_messages\030\001 \003(\013"
-          + "2!.google.pubsub.v1.ReceivedMessageB\003\340A\001"
-          + "\022f\n\030acknowledge_confirmation\030\005 \001(\0132?.goo"
-          + "gle.pubsub.v1.StreamingPullResponse.Ackn"
-          + "owledgeConfirmationB\003\340A\001\022t\n modify_ack_d"
-          + "eadline_confirmation\030\003 \001(\0132E.google.pubs"
-          + "ub.v1.StreamingPullResponse.ModifyAckDea"
-          + "dlineConfirmationB\003\340A\001\022d\n\027subscription_p"
-          + "roperties\030\004 \001(\0132>.google.pubsub.v1.Strea"
-          + "mingPullResponse.SubscriptionPropertiesB"
-          + "\003\340A\001\032\224\001\n\027AcknowledgeConfirmation\022\024\n\007ack_"
-          + "ids\030\001 \003(\tB\003\340A\001\022\034\n\017invalid_ack_ids\030\002 \003(\tB"
-          + "\003\340A\001\022\036\n\021unordered_ack_ids\030\003 \003(\tB\003\340A\001\022%\n\030"
-          + "temporary_failed_ack_ids\030\004 \003(\tB\003\340A\001\032z\n\035M"
-          + "odifyAckDeadlineConfirmation\022\024\n\007ack_ids\030"
-          + "\001 \003(\tB\003\340A\001\022\034\n\017invalid_ack_ids\030\002 \003(\tB\003\340A\001"
-          + "\022%\n\030temporary_failed_ack_ids\030\003 \003(\tB\003\340A\001\032"
-          + "k\n\026SubscriptionProperties\022*\n\035exactly_onc"
-          + "e_delivery_enabled\030\001 \001(\010B\003\340A\001\022%\n\030message"
-          + "_ordering_enabled\030\002 \001(\010B\003\340A\001\"\210\002\n\025CreateS"
-          + "napshotRequest\0224\n\004name\030\001 \001(\tB&\340A\002\372A \n\036pu"
-          + "bsub.googleapis.com/Snapshot\022@\n\014subscrip"
-          + "tion\030\002 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.co"
-          + "m/Subscription\022H\n\006labels\030\003 \003(\01323.google."
-          + "pubsub.v1.CreateSnapshotRequest.LabelsEn"
-          + "tryB\003\340A\001\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005"
-          + "value\030\002 \001(\t:\0028\001\"\200\001\n\025UpdateSnapshotReques"
-          + "t\0221\n\010snapshot\030\001 \001(\0132\032.google.pubsub.v1.S"
-          + "napshotB\003\340A\002\0224\n\013update_mask\030\002 \001(\0132\032.goog"
-          + "le.protobuf.FieldMaskB\003\340A\002\"\301\002\n\010Snapshot\022"
-          + "\021\n\004name\030\001 \001(\tB\003\340A\001\0222\n\005topic\030\002 \001(\tB#\340A\001\372A"
-          + "\035\n\033pubsub.googleapis.com/Topic\0224\n\013expire"
-          + "_time\030\003 \001(\0132\032.google.protobuf.TimestampB"
-          + "\003\340A\001\022;\n\006labels\030\004 \003(\0132&.google.pubsub.v1."
-          + "Snapshot.LabelsEntryB\003\340A\001\032-\n\013LabelsEntry"
-          + "\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001:L\352AI\n\036p"
-          + "ubsub.googleapis.com/Snapshot\022\'projects/"
-          + "{project}/snapshots/{snapshot}\"N\n\022GetSna"
-          + "pshotRequest\0228\n\010snapshot\030\001 \001(\tB&\340A\002\372A \n\036"
-          + "pubsub.googleapis.com/Snapshot\"\215\001\n\024ListS"
-          + "napshotsRequest\022D\n\007project\030\001 \001(\tB3\340A\002\372A-"
-          + "\n+cloudresourcemanager.googleapis.com/Pr"
-          + "oject\022\026\n\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\npage_to"
-          + "ken\030\003 \001(\tB\003\340A\001\"i\n\025ListSnapshotsResponse\022"
-          + "2\n\tsnapshots\030\001 \003(\0132\032.google.pubsub.v1.Sn"
-          + "apshotB\003\340A\001\022\034\n\017next_page_token\030\002 \001(\tB\003\340A"
-          + "\001\"Q\n\025DeleteSnapshotRequest\0228\n\010snapshot\030\001"
-          + " \001(\tB&\340A\002\372A \n\036pubsub.googleapis.com/Snap"
-          + "shot\"\306\001\n\013SeekRequest\022@\n\014subscription\030\001 \001"
+          + "count_email\030\013 \001(\tB\003\340A\001\032\014\n\nTextConfig\032H\n\n"
+          + "AvroConfig\022\033\n\016write_metadata\030\001 \001(\010B\003\340A\001\022"
+          + "\035\n\020use_topic_schema\030\002 \001(\010B\003\340A\001\"\212\001\n\005State"
+          + "\022\025\n\021STATE_UNSPECIFIED\020\000\022\n\n\006ACTIVE\020\001\022\025\n\021P"
+          + "ERMISSION_DENIED\020\002\022\r\n\tNOT_FOUND\020\003\022#\n\037IN_"
+          + "TRANSIT_LOCATION_RESTRICTION\020\004\022\023\n\017SCHEMA"
+          + "_MISMATCH\020\005B\017\n\routput_format\"|\n\017Received"
+          + "Message\022\023\n\006ack_id\030\001 \001(\tB\003\340A\001\0225\n\007message\030"
+          + "\002 \001(\0132\037.google.pubsub.v1.PubsubMessageB\003"
+          + "\340A\001\022\035\n\020delivery_attempt\030\003 \001(\005B\003\340A\001\"Z\n\026Ge"
+          + "tSubscriptionRequest\022@\n\014subscription\030\001 \001"
           + "(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Subscr"
-          + "iption\022/\n\004time\030\002 \001(\0132\032.google.protobuf.T"
-          + "imestampB\003\340A\001H\000\022:\n\010snapshot\030\003 \001(\tB&\340A\001\372A"
-          + " \n\036pubsub.googleapis.com/SnapshotH\000B\010\n\006t"
-          + "arget\"\016\n\014SeekResponse2\270\013\n\tPublisher\022q\n\013C"
-          + "reateTopic\022\027.google.pubsub.v1.Topic\032\027.go"
-          + "ogle.pubsub.v1.Topic\"0\332A\004name\202\323\344\223\002#\032\036/v1"
-          + "/{name=projects/*/topics/*}:\001*\022\221\001\n\013Updat"
-          + "eTopic\022$.google.pubsub.v1.UpdateTopicReq"
-          + "uest\032\027.google.pubsub.v1.Topic\"C\332A\021topic,"
-          + "update_mask\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\332A\016topic,messages\202\323"
-          + "\344\223\002,\"\'/v1/{topic=projects/*/topics/*}:pu"
-          + "blish:\001*\022w\n\010GetTopic\022!.google.pubsub.v1."
-          + "GetTopicRequest\032\027.google.pubsub.v1.Topic"
-          + "\"/\332A\005topic\202\323\344\223\002!\022\037/v1/{topic=projects/*/"
-          + "topics/*}\022\212\001\n\nListTopics\022#.google.pubsub"
-          + ".v1.ListTopicsRequest\032$.google.pubsub.v1"
-          + ".ListTopicsResponse\"1\332A\007project\202\323\344\223\002!\022\037/"
-          + "v1/{project=projects/*}/topics\022\272\001\n\026ListT"
-          + "opicSubscriptions\022/.google.pubsub.v1.Lis"
-          + "tTopicSubscriptionsRequest\0320.google.pubs"
-          + "ub.v1.ListTopicSubscriptionsResponse\"=\332A"
-          + "\005topic\202\323\344\223\002/\022-/v1/{topic=projects/*/topi"
-          + "cs/*}/subscriptions\022\252\001\n\022ListTopicSnapsho"
-          + "ts\022+.google.pubsub.v1.ListTopicSnapshots"
-          + "Request\032,.google.pubsub.v1.ListTopicSnap"
-          + "shotsResponse\"9\332A\005topic\202\323\344\223\002+\022)/v1/{topi"
-          + "c=projects/*/topics/*}/snapshots\022|\n\013Dele"
-          + "teTopic\022$.google.pubsub.v1.DeleteTopicRe"
-          + "quest\032\026.google.protobuf.Empty\"/\332A\005topic\202"
-          + "\323\344\223\002!*\037/v1/{topic=projects/*/topics/*}\022\255"
-          + "\001\n\022DetachSubscription\022+.google.pubsub.v1"
-          + ".DetachSubscriptionRequest\032,.google.pubs"
-          + "ub.v1.DetachSubscriptionResponse\"<\202\323\344\223\0026"
-          + "\"4/v1/{subscription=projects/*/subscript"
-          + "ions/*}:detach\032p\312A\025pubsub.googleapis.com"
-          + "\322AUhttps://www.googleapis.com/auth/cloud"
-          + "-platform,https://www.googleapis.com/aut"
-          + "h/pubsub2\322\025\n\nSubscriber\022\264\001\n\022CreateSubscr"
-          + "iption\022\036.google.pubsub.v1.Subscription\032\036"
-          + ".google.pubsub.v1.Subscription\"^\332A+name,"
-          + "topic,push_config,ack_deadline_seconds\202\323"
-          + "\344\223\002*\032%/v1/{name=projects/*/subscriptions"
-          + "/*}:\001*\022\241\001\n\017GetSubscription\022(.google.pubs"
-          + "ub.v1.GetSubscriptionRequest\032\036.google.pu"
-          + "bsub.v1.Subscription\"D\332A\014subscription\202\323\344"
-          + "\223\002/\022-/v1/{subscription=projects/*/subscr"
-          + "iptions/*}\022\273\001\n\022UpdateSubscription\022+.goog"
-          + "le.pubsub.v1.UpdateSubscriptionRequest\032\036"
-          + ".google.pubsub.v1.Subscription\"X\332A\030subsc"
-          + "ription,update_mask\202\323\344\223\002722/v1/{subscrip"
-          + "tion.name=projects/*/subscriptions/*}:\001*"
-          + "\022\246\001\n\021ListSubscriptions\022*.google.pubsub.v"
-          + "1.ListSubscriptionsRequest\032+.google.pubs"
-          + "ub.v1.ListSubscriptionsResponse\"8\332A\007proj"
-          + "ect\202\323\344\223\002(\022&/v1/{project=projects/*}/subs"
-          + "criptions\022\237\001\n\022DeleteSubscription\022+.googl"
-          + "e.pubsub.v1.DeleteSubscriptionRequest\032\026."
-          + "google.protobuf.Empty\"D\332A\014subscription\202\323"
-          + "\344\223\002/*-/v1/{subscription=projects/*/subsc"
-          + "riptions/*}\022\317\001\n\021ModifyAckDeadline\022*.goog"
-          + "le.pubsub.v1.ModifyAckDeadlineRequest\032\026."
-          + "google.protobuf.Empty\"v\332A)subscription,a"
-          + "ck_ids,ack_deadline_seconds\202\323\344\223\002D\"?/v1/{"
-          + "subscription=projects/*/subscriptions/*}"
-          + ":modifyAckDeadline:\001*\022\250\001\n\013Acknowledge\022$."
-          + "google.pubsub.v1.AcknowledgeRequest\032\026.go"
-          + "ogle.protobuf.Empty\"[\332A\024subscription,ack"
-          + "_ids\202\323\344\223\002>\"9/v1/{subscription=projects/*"
-          + "/subscriptions/*}:acknowledge:\001*\022\320\001\n\004Pul"
-          + "l\022\035.google.pubsub.v1.PullRequest\032\036.googl"
-          + "e.pubsub.v1.PullResponse\"\210\001\332A,subscripti"
-          + "on,return_immediately,max_messages\332A\031sub"
-          + "scription,max_messages\202\323\344\223\0027\"2/v1/{subsc"
-          + "ription=projects/*/subscriptions/*}:pull"
-          + ":\001*\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\332A\030"
-          + "subscription,push_config\202\323\344\223\002C\">/v1/{sub"
-          + "scription=projects/*/subscriptions/*}:mo"
-          + "difyPushConfig:\001*\022\211\001\n\013GetSnapshot\022$.goog"
-          + "le.pubsub.v1.GetSnapshotRequest\032\032.google"
-          + ".pubsub.v1.Snapshot\"8\332A\010snapshot\202\323\344\223\002\'\022%"
-          + "/v1/{snapshot=projects/*/snapshots/*}\022\226\001"
-          + "\n\rListSnapshots\022&.google.pubsub.v1.ListS"
-          + "napshotsRequest\032\'.google.pubsub.v1.ListS"
-          + "napshotsResponse\"4\332A\007project\202\323\344\223\002$\022\"/v1/"
-          + "{project=projects/*}/snapshots\022\227\001\n\016Creat"
-          + "eSnapshot\022\'.google.pubsub.v1.CreateSnaps"
-          + "hotRequest\032\032.google.pubsub.v1.Snapshot\"@"
-          + "\332A\021name,subscription\202\323\344\223\002&\032!/v1/{name=pr"
-          + "ojects/*/snapshots/*}:\001*\022\243\001\n\016UpdateSnaps"
-          + "hot\022\'.google.pubsub.v1.UpdateSnapshotReq"
-          + "uest\032\032.google.pubsub.v1.Snapshot\"L\332A\024sna"
-          + "pshot,update_mask\202\323\344\223\002/2*/v1/{snapshot.n"
-          + "ame=projects/*/snapshots/*}:\001*\022\213\001\n\016Delet"
-          + "eSnapshot\022\'.google.pubsub.v1.DeleteSnaps"
-          + "hotRequest\032\026.google.protobuf.Empty\"8\332A\010s"
-          + "napshot\202\323\344\223\002\'*%/v1/{snapshot=projects/*/"
-          + "snapshots/*}\022\204\001\n\004Seek\022\035.google.pubsub.v1"
-          + ".SeekRequest\032\036.google.pubsub.v1.SeekResp"
-          + "onse\"=\202\323\344\223\0027\"2/v1/{subscription=projects"
-          + "/*/subscriptions/*}:seek:\001*\032p\312A\025pubsub.g"
+          + "iption\"\214\001\n\031UpdateSubscriptionRequest\0229\n\014"
+          + "subscription\030\001 \001(\0132\036.google.pubsub.v1.Su"
+          + "bscriptionB\003\340A\002\0224\n\013update_mask\030\002 \001(\0132\032.g"
+          + "oogle.protobuf.FieldMaskB\003\340A\002\"\221\001\n\030ListSu"
+          + "bscriptionsRequest\022D\n\007project\030\001 \001(\tB3\340A\002"
+          + "\372A-\n+cloudresourcemanager.googleapis.com"
+          + "/Project\022\026\n\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\npage"
+          + "_token\030\003 \001(\tB\003\340A\001\"u\n\031ListSubscriptionsRe"
+          + "sponse\022:\n\rsubscriptions\030\001 \003(\0132\036.google.p"
+          + "ubsub.v1.SubscriptionB\003\340A\001\022\034\n\017next_page_"
+          + "token\030\002 \001(\tB\003\340A\001\"]\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\"\215\001\n\013PullRequest\022@\n"
+          + "\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.goog"
+          + "leapis.com/Subscription\022!\n\022return_immedi"
+          + "ately\030\002 \001(\010B\005\030\001\340A\001\022\031\n\014max_messages\030\003 \001(\005"
+          + "B\003\340A\002\"Q\n\014PullResponse\022A\n\021received_messag"
+          + "es\030\001 \003(\0132!.google.pubsub.v1.ReceivedMess"
+          + "ageB\003\340A\001\"\225\001\n\030ModifyAckDeadlineRequest\022@\n"
+          + "\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.goog"
+          + "leapis.com/Subscription\022\024\n\007ack_ids\030\004 \003(\t"
+          + "B\003\340A\002\022!\n\024ack_deadline_seconds\030\003 \001(\005B\003\340A\002"
+          + "\"l\n\022AcknowledgeRequest\022@\n\014subscription\030\001"
+          + " \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Subs"
+          + "cription\022\024\n\007ack_ids\030\002 \003(\tB\003\340A\002\"\307\002\n\024Strea"
+          + "mingPullRequest\022@\n\014subscription\030\001 \001(\tB*\340"
+          + "A\002\372A$\n\"pubsub.googleapis.com/Subscriptio"
+          + "n\022\024\n\007ack_ids\030\002 \003(\tB\003\340A\001\022$\n\027modify_deadli"
+          + "ne_seconds\030\003 \003(\005B\003\340A\001\022$\n\027modify_deadline"
+          + "_ack_ids\030\004 \003(\tB\003\340A\001\022(\n\033stream_ack_deadli"
+          + "ne_seconds\030\005 \001(\005B\003\340A\002\022\026\n\tclient_id\030\006 \001(\t"
+          + "B\003\340A\001\022%\n\030max_outstanding_messages\030\007 \001(\003B"
+          + "\003\340A\001\022\"\n\025max_outstanding_bytes\030\010 \001(\003B\003\340A\001"
+          + "\"\236\006\n\025StreamingPullResponse\022A\n\021received_m"
+          + "essages\030\001 \003(\0132!.google.pubsub.v1.Receive"
+          + "dMessageB\003\340A\001\022f\n\030acknowledge_confirmatio"
+          + "n\030\005 \001(\0132?.google.pubsub.v1.StreamingPull"
+          + "Response.AcknowledgeConfirmationB\003\340A\001\022t\n"
+          + " modify_ack_deadline_confirmation\030\003 \001(\0132"
+          + "E.google.pubsub.v1.StreamingPullResponse"
+          + ".ModifyAckDeadlineConfirmationB\003\340A\001\022d\n\027s"
+          + "ubscription_properties\030\004 \001(\0132>.google.pu"
+          + "bsub.v1.StreamingPullResponse.Subscripti"
+          + "onPropertiesB\003\340A\001\032\224\001\n\027AcknowledgeConfirm"
+          + "ation\022\024\n\007ack_ids\030\001 \003(\tB\003\340A\001\022\034\n\017invalid_a"
+          + "ck_ids\030\002 \003(\tB\003\340A\001\022\036\n\021unordered_ack_ids\030\003"
+          + " \003(\tB\003\340A\001\022%\n\030temporary_failed_ack_ids\030\004 "
+          + "\003(\tB\003\340A\001\032z\n\035ModifyAckDeadlineConfirmatio"
+          + "n\022\024\n\007ack_ids\030\001 \003(\tB\003\340A\001\022\034\n\017invalid_ack_i"
+          + "ds\030\002 \003(\tB\003\340A\001\022%\n\030temporary_failed_ack_id"
+          + "s\030\003 \003(\tB\003\340A\001\032k\n\026SubscriptionProperties\022*"
+          + "\n\035exactly_once_delivery_enabled\030\001 \001(\010B\003\340"
+          + "A\001\022%\n\030message_ordering_enabled\030\002 \001(\010B\003\340A"
+          + "\001\"\210\002\n\025CreateSnapshotRequest\0224\n\004name\030\001 \001("
+          + "\tB&\340A\002\372A \n\036pubsub.googleapis.com/Snapsho"
+          + "t\022@\n\014subscription\030\002 \001(\tB*\340A\002\372A$\n\"pubsub."
+          + "googleapis.com/Subscription\022H\n\006labels\030\003 "
+          + "\003(\01323.google.pubsub.v1.CreateSnapshotReq"
+          + "uest.LabelsEntryB\003\340A\001\032-\n\013LabelsEntry\022\013\n\003"
+          + "key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\200\001\n\025UpdateS"
+          + "napshotRequest\0221\n\010snapshot\030\001 \001(\0132\032.googl"
+          + "e.pubsub.v1.SnapshotB\003\340A\002\0224\n\013update_mask"
+          + "\030\002 \001(\0132\032.google.protobuf.FieldMaskB\003\340A\002\""
+          + "\301\002\n\010Snapshot\022\021\n\004name\030\001 \001(\tB\003\340A\001\0222\n\005topic"
+          + "\030\002 \001(\tB#\340A\001\372A\035\n\033pubsub.googleapis.com/To"
+          + "pic\0224\n\013expire_time\030\003 \001(\0132\032.google.protob"
+          + "uf.TimestampB\003\340A\001\022;\n\006labels\030\004 \003(\0132&.goog"
+          + "le.pubsub.v1.Snapshot.LabelsEntryB\003\340A\001\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\"\215\001\n\024ListSnapshotsRequest\022D\n\007project\030"
+          + "\001 \001(\tB3\340A\002\372A-\n+cloudresourcemanager.goog"
+          + "leapis.com/Project\022\026\n\tpage_size\030\002 \001(\005B\003\340"
+          + "A\001\022\027\n\npage_token\030\003 \001(\tB\003\340A\001\"i\n\025ListSnaps"
+          + "hotsResponse\0222\n\tsnapshots\030\001 \003(\0132\032.google"
+          + ".pubsub.v1.SnapshotB\003\340A\001\022\034\n\017next_page_to"
+          + "ken\030\002 \001(\tB\003\340A\001\"Q\n\025DeleteSnapshotRequest\022"
+          + "8\n\010snapshot\030\001 \001(\tB&\340A\002\372A \n\036pubsub.google"
+          + "apis.com/Snapshot\"\306\001\n\013SeekRequest\022@\n\014sub"
+          + "scription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleap"
+          + "is.com/Subscription\022/\n\004time\030\002 \001(\0132\032.goog"
+          + "le.protobuf.TimestampB\003\340A\001H\000\022:\n\010snapshot"
+          + "\030\003 \001(\tB&\340A\001\372A \n\036pubsub.googleapis.com/Sn"
+          + "apshotH\000B\010\n\006target\"\016\n\014SeekResponse2\270\013\n\tP"
+          + "ublisher\022q\n\013CreateTopic\022\027.google.pubsub."
+          + "v1.Topic\032\027.google.pubsub.v1.Topic\"0\332A\004na"
+          + "me\202\323\344\223\002#\032\036/v1/{name=projects/*/topics/*}"
+          + ":\001*\022\221\001\n\013UpdateTopic\022$.google.pubsub.v1.U"
+          + "pdateTopicRequest\032\027.google.pubsub.v1.Top"
+          + "ic\"C\332A\021topic,update_mask\202\323\344\223\002)2$/v1/{top"
+          + "ic.name=projects/*/topics/*}:\001*\022\223\001\n\007Publ"
+          + "ish\022 .google.pubsub.v1.PublishRequest\032!."
+          + "google.pubsub.v1.PublishResponse\"C\332A\016top"
+          + "ic,messages\202\323\344\223\002,\"\'/v1/{topic=projects/*"
+          + "/topics/*}:publish:\001*\022w\n\010GetTopic\022!.goog"
+          + "le.pubsub.v1.GetTopicRequest\032\027.google.pu"
+          + "bsub.v1.Topic\"/\332A\005topic\202\323\344\223\002!\022\037/v1/{topi"
+          + "c=projects/*/topics/*}\022\212\001\n\nListTopics\022#."
+          + "google.pubsub.v1.ListTopicsRequest\032$.goo"
+          + "gle.pubsub.v1.ListTopicsResponse\"1\332A\007pro"
+          + "ject\202\323\344\223\002!\022\037/v1/{project=projects/*}/top"
+          + "ics\022\272\001\n\026ListTopicSubscriptions\022/.google."
+          + "pubsub.v1.ListTopicSubscriptionsRequest\032"
+          + "0.google.pubsub.v1.ListTopicSubscription"
+          + "sResponse\"=\332A\005topic\202\323\344\223\002/\022-/v1/{topic=pr"
+          + "ojects/*/topics/*}/subscriptions\022\252\001\n\022Lis"
+          + "tTopicSnapshots\022+.google.pubsub.v1.ListT"
+          + "opicSnapshotsRequest\032,.google.pubsub.v1."
+          + "ListTopicSnapshotsResponse\"9\332A\005topic\202\323\344\223"
+          + "\002+\022)/v1/{topic=projects/*/topics/*}/snap"
+          + "shots\022|\n\013DeleteTopic\022$.google.pubsub.v1."
+          + "DeleteTopicRequest\032\026.google.protobuf.Emp"
+          + "ty\"/\332A\005topic\202\323\344\223\002!*\037/v1/{topic=projects/"
+          + "*/topics/*}\022\255\001\n\022DetachSubscription\022+.goo"
+          + "gle.pubsub.v1.DetachSubscriptionRequest\032"
+          + ",.google.pubsub.v1.DetachSubscriptionRes"
+          + "ponse\"<\202\323\344\223\0026\"4/v1/{subscription=project"
+          + "s/*/subscriptions/*}:detach\032p\312A\025pubsub.g"
           + "oogleapis.com\322AUhttps://www.googleapis.c"
           + "om/auth/cloud-platform,https://www.googl"
-          + "eapis.com/auth/pubsubB\252\001\n\024com.google.pub"
-          + "sub.v1B\013PubsubProtoP\001Z2cloud.google.com/"
-          + "go/pubsub/apiv1/pubsubpb;pubsubpb\370\001\001\252\002\026G"
-          + "oogle.Cloud.PubSub.V1\312\002\026Google\\Cloud\\Pub"
-          + "Sub\\V1\352\002\031Google::Cloud::PubSub::V1b\006prot"
-          + "o3"
+          + "eapis.com/auth/pubsub2\322\025\n\nSubscriber\022\264\001\n"
+          + "\022CreateSubscription\022\036.google.pubsub.v1.S"
+          + "ubscription\032\036.google.pubsub.v1.Subscript"
+          + "ion\"^\332A+name,topic,push_config,ack_deadl"
+          + "ine_seconds\202\323\344\223\002*\032%/v1/{name=projects/*/"
+          + "subscriptions/*}:\001*\022\241\001\n\017GetSubscription\022"
+          + "(.google.pubsub.v1.GetSubscriptionReques"
+          + "t\032\036.google.pubsub.v1.Subscription\"D\332A\014su"
+          + "bscription\202\323\344\223\002/\022-/v1/{subscription=proj"
+          + "ects/*/subscriptions/*}\022\273\001\n\022UpdateSubscr"
+          + "iption\022+.google.pubsub.v1.UpdateSubscrip"
+          + "tionRequest\032\036.google.pubsub.v1.Subscript"
+          + "ion\"X\332A\030subscription,update_mask\202\323\344\223\002722"
+          + "/v1/{subscription.name=projects/*/subscr"
+          + "iptions/*}:\001*\022\246\001\n\021ListSubscriptions\022*.go"
+          + "ogle.pubsub.v1.ListSubscriptionsRequest\032"
+          + "+.google.pubsub.v1.ListSubscriptionsResp"
+          + "onse\"8\332A\007project\202\323\344\223\002(\022&/v1/{project=pro"
+          + "jects/*}/subscriptions\022\237\001\n\022DeleteSubscri"
+          + "ption\022+.google.pubsub.v1.DeleteSubscript"
+          + "ionRequest\032\026.google.protobuf.Empty\"D\332A\014s"
+          + "ubscription\202\323\344\223\002/*-/v1/{subscription=pro"
+          + "jects/*/subscriptions/*}\022\317\001\n\021ModifyAckDe"
+          + "adline\022*.google.pubsub.v1.ModifyAckDeadl"
+          + "ineRequest\032\026.google.protobuf.Empty\"v\332A)s"
+          + "ubscription,ack_ids,ack_deadline_seconds"
+          + "\202\323\344\223\002D\"?/v1/{subscription=projects/*/sub"
+          + "scriptions/*}:modifyAckDeadline:\001*\022\250\001\n\013A"
+          + "cknowledge\022$.google.pubsub.v1.Acknowledg"
+          + "eRequest\032\026.google.protobuf.Empty\"[\332A\024sub"
+          + "scription,ack_ids\202\323\344\223\002>\"9/v1/{subscripti"
+          + "on=projects/*/subscriptions/*}:acknowled"
+          + "ge:\001*\022\320\001\n\004Pull\022\035.google.pubsub.v1.PullRe"
+          + "quest\032\036.google.pubsub.v1.PullResponse\"\210\001"
+          + "\332A,subscription,return_immediately,max_m"
+          + "essages\332A\031subscription,max_messages\202\323\344\223\002"
+          + "7\"2/v1/{subscription=projects/*/subscrip"
+          + "tions/*}:pull:\001*\022f\n\rStreamingPull\022&.goog"
+          + "le.pubsub.v1.StreamingPullRequest\032\'.goog"
+          + "le.pubsub.v1.StreamingPullResponse\"\000(\0010\001"
+          + "\022\273\001\n\020ModifyPushConfig\022).google.pubsub.v1"
+          + ".ModifyPushConfigRequest\032\026.google.protob"
+          + "uf.Empty\"d\332A\030subscription,push_config\202\323\344"
+          + "\223\002C\">/v1/{subscription=projects/*/subscr"
+          + "iptions/*}:modifyPushConfig:\001*\022\211\001\n\013GetSn"
+          + "apshot\022$.google.pubsub.v1.GetSnapshotReq"
+          + "uest\032\032.google.pubsub.v1.Snapshot\"8\332A\010sna"
+          + "pshot\202\323\344\223\002\'\022%/v1/{snapshot=projects/*/sn"
+          + "apshots/*}\022\226\001\n\rListSnapshots\022&.google.pu"
+          + "bsub.v1.ListSnapshotsRequest\032\'.google.pu"
+          + "bsub.v1.ListSnapshotsResponse\"4\332A\007projec"
+          + "t\202\323\344\223\002$\022\"/v1/{project=projects/*}/snapsh"
+          + "ots\022\227\001\n\016CreateSnapshot\022\'.google.pubsub.v"
+          + "1.CreateSnapshotRequest\032\032.google.pubsub."
+          + "v1.Snapshot\"@\332A\021name,subscription\202\323\344\223\002&\032"
+          + "!/v1/{name=projects/*/snapshots/*}:\001*\022\243\001"
+          + "\n\016UpdateSnapshot\022\'.google.pubsub.v1.Upda"
+          + "teSnapshotRequest\032\032.google.pubsub.v1.Sna"
+          + "pshot\"L\332A\024snapshot,update_mask\202\323\344\223\002/2*/v"
+          + "1/{snapshot.name=projects/*/snapshots/*}"
+          + ":\001*\022\213\001\n\016DeleteSnapshot\022\'.google.pubsub.v"
+          + "1.DeleteSnapshotRequest\032\026.google.protobu"
+          + "f.Empty\"8\332A\010snapshot\202\323\344\223\002\'*%/v1/{snapsho"
+          + "t=projects/*/snapshots/*}\022\204\001\n\004Seek\022\035.goo"
+          + "gle.pubsub.v1.SeekRequest\032\036.google.pubsu"
+          + "b.v1.SeekResponse\"=\202\323\344\223\0027\"2/v1/{subscrip"
+          + "tion=projects/*/subscriptions/*}:seek:\001*"
+          + "\032p\312A\025pubsub.googleapis.com\322AUhttps://www"
+          + ".googleapis.com/auth/cloud-platform,http"
+          + "s://www.googleapis.com/auth/pubsubB\252\001\n\024c"
+          + "om.google.pubsub.v1B\013PubsubProtoP\001Z2clou"
+          + "d.google.com/go/pubsub/apiv1/pubsubpb;pu"
+          + "bsubpb\370\001\001\252\002\026Google.Cloud.PubSub.V1\312\002\026Goo"
+          + "gle\\Cloud\\PubSub\\V1\352\002\031Google::Cloud::Pub"
+          + "Sub::V1b\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -987,7 +988,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
         new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
             internal_static_google_pubsub_v1_CloudStorageConfig_AvroConfig_descriptor,
             new java.lang.String[] {
-              "WriteMetadata",
+              "WriteMetadata", "UseTopicSchema",
             });
     internal_static_google_pubsub_v1_ReceivedMessage_descriptor =
         getDescriptor().getMessageTypes().get(25);
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 5341666eb..a26effb78 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
@@ -137,7 +137,7 @@ public com.google.protobuf.ByteString getSubscriptionBytes() {
    * </code>
    *
    * @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
-   *     google/pubsub/v1/pubsub.proto;l=1379
+   *     google/pubsub/v1/pubsub.proto;l=1387
    * @return The returnImmediately.
    */
   @java.lang.Override
@@ -688,7 +688,7 @@ public Builder setSubscriptionBytes(com.google.protobuf.ByteString value) {
      * </code>
      *
      * @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
-     *     google/pubsub/v1/pubsub.proto;l=1379
+     *     google/pubsub/v1/pubsub.proto;l=1387
      * @return The returnImmediately.
      */
     @java.lang.Override
@@ -714,7 +714,7 @@ public boolean getReturnImmediately() {
      * </code>
      *
      * @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
-     *     google/pubsub/v1/pubsub.proto;l=1379
+     *     google/pubsub/v1/pubsub.proto;l=1387
      * @param value The returnImmediately to set.
      * @return This builder for chaining.
      */
@@ -744,7 +744,7 @@ public Builder setReturnImmediately(boolean value) {
      * </code>
      *
      * @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
-     *     google/pubsub/v1/pubsub.proto;l=1379
+     *     google/pubsub/v1/pubsub.proto;l=1387
      * @return This builder for chaining.
      */
     @java.lang.Deprecated
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 2dc2208a4..94c2e0c10 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
@@ -72,7 +72,7 @@ public interface PullRequestOrBuilder
    * </code>
    *
    * @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
-   *     google/pubsub/v1/pubsub.proto;l=1379
+   *     google/pubsub/v1/pubsub.proto;l=1387
    * @return The returnImmediately.
    */
   @java.lang.Deprecated
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 8546dacf9..b70bda11a 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
@@ -1168,6 +1168,10 @@ message CloudStorageConfig {
     // data (for example, an ordering_key, if present) are added as entries in
     // the attributes map.
     bool write_metadata = 1 [(google.api.field_behavior) = OPTIONAL];
+
+    // Optional. When true, the output Cloud Storage file will be serialized
+    // using the topic schema, if it exists.
+    bool use_topic_schema = 2 [(google.api.field_behavior) = OPTIONAL];
   }
 
   // Possible states for a Cloud Storage subscription.
@@ -1188,6 +1192,10 @@ message CloudStorageConfig {
     // Cannot write to the destination because enforce_in_transit is set to true
     // and the destination locations are not in the allowed regions.
     IN_TRANSIT_LOCATION_RESTRICTION = 4;
+
+    // Cannot write to the Cloud Storage bucket due to an incompatibility
+    // between the topic schema and subscription settings.
+    SCHEMA_MISMATCH = 5;
   }
 
   // Required. User-provided name for the Cloud Storage bucket.