diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfig.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfig.java
index 67b06239d..66323e6af 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfig.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfig.java
@@ -41,6 +41,7 @@ private BigQueryConfig(com.google.protobuf.GeneratedMessageV3.Builder builder
private BigQueryConfig() {
table_ = "";
state_ = 0;
+ serviceAccountEmail_ = "";
}
@java.lang.Override
@@ -477,6 +478,67 @@ public boolean getUseTableSchema() {
return useTableSchema_;
}
+ public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER = 7;
+
+ @SuppressWarnings("serial")
+ private volatile java.lang.Object serviceAccountEmail_ = "";
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ @java.lang.Override
+ public java.lang.String getServiceAccountEmail() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ serviceAccountEmail_ = s;
+ return s;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ serviceAccountEmail_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -509,6 +571,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (useTableSchema_ != false) {
output.writeBool(6, useTableSchema_);
}
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 7, serviceAccountEmail_);
+ }
getUnknownFields().writeTo(output);
}
@@ -536,6 +601,9 @@ public int getSerializedSize() {
if (useTableSchema_ != false) {
size += com.google.protobuf.CodedOutputStream.computeBoolSize(6, useTableSchema_);
}
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(7, serviceAccountEmail_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -557,6 +625,7 @@ public boolean equals(final java.lang.Object obj) {
if (getDropUnknownFields() != other.getDropUnknownFields()) return false;
if (state_ != other.state_) return false;
if (getUseTableSchema() != other.getUseTableSchema()) return false;
+ if (!getServiceAccountEmail().equals(other.getServiceAccountEmail())) return false;
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@@ -580,6 +649,8 @@ public int hashCode() {
hash = (53 * hash) + state_;
hash = (37 * hash) + USE_TABLE_SCHEMA_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getUseTableSchema());
+ hash = (37 * hash) + SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER;
+ hash = (53 * hash) + getServiceAccountEmail().hashCode();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
@@ -724,6 +795,7 @@ public Builder clear() {
dropUnknownFields_ = false;
state_ = 0;
useTableSchema_ = false;
+ serviceAccountEmail_ = "";
return this;
}
@@ -777,6 +849,9 @@ private void buildPartial0(com.google.pubsub.v1.BigQueryConfig result) {
if (((from_bitField0_ & 0x00000020) != 0)) {
result.useTableSchema_ = useTableSchema_;
}
+ if (((from_bitField0_ & 0x00000040) != 0)) {
+ result.serviceAccountEmail_ = serviceAccountEmail_;
+ }
}
@java.lang.Override
@@ -844,6 +919,11 @@ public Builder mergeFrom(com.google.pubsub.v1.BigQueryConfig other) {
if (other.getUseTableSchema() != false) {
setUseTableSchema(other.getUseTableSchema());
}
+ if (!other.getServiceAccountEmail().isEmpty()) {
+ serviceAccountEmail_ = other.serviceAccountEmail_;
+ bitField0_ |= 0x00000040;
+ onChanged();
+ }
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
@@ -906,6 +986,12 @@ public Builder mergeFrom(
bitField0_ |= 0x00000020;
break;
} // case 48
+ case 58:
+ {
+ serviceAccountEmail_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000040;
+ break;
+ } // case 58
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -1389,6 +1475,137 @@ public Builder clearUseTableSchema() {
return this;
}
+ private java.lang.Object serviceAccountEmail_ = "";
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ public java.lang.String getServiceAccountEmail() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ serviceAccountEmail_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ serviceAccountEmail_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @param value The serviceAccountEmail to set.
+ * @return This builder for chaining.
+ */
+ public Builder setServiceAccountEmail(java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ serviceAccountEmail_ = value;
+ bitField0_ |= 0x00000040;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearServiceAccountEmail() {
+ serviceAccountEmail_ = getDefaultInstance().getServiceAccountEmail();
+ bitField0_ = (bitField0_ & ~0x00000040);
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @param value The bytes for serviceAccountEmail to set.
+ * @return This builder for chaining.
+ */
+ public Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ serviceAccountEmail_ = value;
+ bitField0_ |= 0x00000040;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfigOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfigOrBuilder.java
index a2420175d..958a634f2 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfigOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/BigQueryConfigOrBuilder.java
@@ -145,4 +145,39 @@ public interface BigQueryConfigOrBuilder
* @return The useTableSchema.
*/
boolean getUseTableSchema();
+
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ java.lang.String getServiceAccountEmail();
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to BigQuery. The subscription
+ * creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub [service
+ * agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 7 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ com.google.protobuf.ByteString getServiceAccountEmailBytes();
}
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 5d3704a7d..4f98b34b1 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
@@ -44,6 +44,7 @@ private CloudStorageConfig() {
filenameSuffix_ = "";
filenameDatetimeFormat_ = "";
state_ = 0;
+ serviceAccountEmail_ = "";
}
@java.lang.Override
@@ -1770,6 +1771,67 @@ public com.google.pubsub.v1.CloudStorageConfig.State getState() {
return result == null ? com.google.pubsub.v1.CloudStorageConfig.State.UNRECOGNIZED : result;
}
+ public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER = 11;
+
+ @SuppressWarnings("serial")
+ private volatile java.lang.Object serviceAccountEmail_ = "";
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ @java.lang.Override
+ public java.lang.String getServiceAccountEmail() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ serviceAccountEmail_ = s;
+ return s;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ serviceAccountEmail_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -1811,6 +1873,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(filenameDatetimeFormat_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 10, filenameDatetimeFormat_);
}
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 11, serviceAccountEmail_);
+ }
getUnknownFields().writeTo(output);
}
@@ -1851,6 +1916,9 @@ public int getSerializedSize() {
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(filenameDatetimeFormat_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(10, filenameDatetimeFormat_);
}
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(11, serviceAccountEmail_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -1876,6 +1944,7 @@ public boolean equals(final java.lang.Object obj) {
}
if (getMaxBytes() != other.getMaxBytes()) return false;
if (state_ != other.state_) return false;
+ if (!getServiceAccountEmail().equals(other.getServiceAccountEmail())) return false;
if (!getOutputFormatCase().equals(other.getOutputFormatCase())) return false;
switch (outputFormatCase_) {
case 4:
@@ -1914,6 +1983,8 @@ public int hashCode() {
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxBytes());
hash = (37 * hash) + STATE_FIELD_NUMBER;
hash = (53 * hash) + state_;
+ hash = (37 * hash) + SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER;
+ hash = (53 * hash) + getServiceAccountEmail().hashCode();
switch (outputFormatCase_) {
case 4:
hash = (37 * hash) + TEXT_CONFIG_FIELD_NUMBER;
@@ -2091,6 +2162,7 @@ public Builder clear() {
}
maxBytes_ = 0L;
state_ = 0;
+ serviceAccountEmail_ = "";
outputFormatCase_ = 0;
outputFormat_ = null;
return this;
@@ -2154,6 +2226,9 @@ private void buildPartial0(com.google.pubsub.v1.CloudStorageConfig result) {
if (((from_bitField0_ & 0x00000100) != 0)) {
result.state_ = state_;
}
+ if (((from_bitField0_ & 0x00000200) != 0)) {
+ result.serviceAccountEmail_ = serviceAccountEmail_;
+ }
result.bitField0_ |= to_bitField0_;
}
@@ -2242,6 +2317,11 @@ public Builder mergeFrom(com.google.pubsub.v1.CloudStorageConfig other) {
if (other.state_ != 0) {
setStateValue(other.getStateValue());
}
+ if (!other.getServiceAccountEmail().isEmpty()) {
+ serviceAccountEmail_ = other.serviceAccountEmail_;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ }
switch (other.getOutputFormatCase()) {
case TEXT_CONFIG:
{
@@ -2338,6 +2418,12 @@ public Builder mergeFrom(
bitField0_ |= 0x00000008;
break;
} // case 82
+ case 90:
+ {
+ serviceAccountEmail_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000200;
+ break;
+ } // case 90
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -3685,6 +3771,137 @@ public Builder clearState() {
return this;
}
+ private java.lang.Object serviceAccountEmail_ = "";
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ public java.lang.String getServiceAccountEmail() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ serviceAccountEmail_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
+ java.lang.Object ref = serviceAccountEmail_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
+ serviceAccountEmail_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @param value The serviceAccountEmail to set.
+ * @return This builder for chaining.
+ */
+ public Builder setServiceAccountEmail(java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ serviceAccountEmail_ = value;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearServiceAccountEmail() {
+ serviceAccountEmail_ = getDefaultInstance().getServiceAccountEmail();
+ bitField0_ = (bitField0_ & ~0x00000200);
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @param value The bytes for serviceAccountEmail to set.
+ * @return This builder for chaining.
+ */
+ public Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ serviceAccountEmail_ = value;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfigOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfigOrBuilder.java
index 19eab21ab..11d3fa787 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfigOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CloudStorageConfigOrBuilder.java
@@ -318,5 +318,40 @@ public interface CloudStorageConfigOrBuilder
*/
com.google.pubsub.v1.CloudStorageConfig.State getState();
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The serviceAccountEmail.
+ */
+ java.lang.String getServiceAccountEmail();
+ /**
+ *
+ *
+ *
+ * Optional. The service account to use to write to Cloud Storage. The
+ * subscription creator or updater that specifies this field must have
+ * `iam.serviceAccounts.actAs` permission on the service account. If not
+ * specified, the Pub/Sub
+ * [service agent](https://cloud.google.com/iam/docs/service-agents),
+ * service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ *
+ *
+ * string service_account_email = 11 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ * @return The bytes for serviceAccountEmail.
+ */
+ com.google.protobuf.ByteString getServiceAccountEmailBytes();
+
com.google.pubsub.v1.CloudStorageConfig.OutputFormatCase getOutputFormatCase();
}
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 8fff960ed..4ef81ddb7 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
@@ -417,239 +417,241 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "\032\017\n\rPubsubWrapper\032(\n\tNoWrapper\022\033\n\016write_"
+ "metadata\030\001 \001(\010B\003\340A\001\0321\n\017AttributesEntry\022\013"
+ "\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001B\027\n\025authen"
- + "tication_methodB\t\n\007wrapper\"\352\002\n\016BigQueryC"
+ + "tication_methodB\t\n\007wrapper\"\216\003\n\016BigQueryC"
+ "onfig\022\022\n\005table\030\001 \001(\tB\003\340A\001\022\035\n\020use_topic_s"
+ "chema\030\002 \001(\010B\003\340A\001\022\033\n\016write_metadata\030\003 \001(\010"
+ "B\003\340A\001\022 \n\023drop_unknown_fields\030\004 \001(\010B\003\340A\001\022"
+ ":\n\005state\030\005 \001(\0162&.google.pubsub.v1.BigQue"
+ "ryConfig.StateB\003\340A\003\022\035\n\020use_table_schema\030"
- + "\006 \001(\010B\003\340A\001\"\212\001\n\005State\022\025\n\021STATE_UNSPECIFIE"
- + "D\020\000\022\n\n\006ACTIVE\020\001\022\025\n\021PERMISSION_DENIED\020\002\022\r"
- + "\n\tNOT_FOUND\020\003\022\023\n\017SCHEMA_MISMATCH\020\004\022#\n\037IN"
- + "_TRANSIT_LOCATION_RESTRICTION\020\005\"\365\004\n\022Clou"
- + "dStorageConfig\022\023\n\006bucket\030\001 \001(\tB\003\340A\002\022\034\n\017f"
- + "ilename_prefix\030\002 \001(\tB\003\340A\001\022\034\n\017filename_su"
- + "ffix\030\003 \001(\tB\003\340A\001\022%\n\030filename_datetime_for"
- + "mat\030\n \001(\tB\003\340A\001\022K\n\013text_config\030\004 \001(\0132/.go"
- + "ogle.pubsub.v1.CloudStorageConfig.TextCo"
- + "nfigB\003\340A\001H\000\022K\n\013avro_config\030\005 \001(\0132/.googl"
- + "e.pubsub.v1.CloudStorageConfig.AvroConfi"
- + "gB\003\340A\001H\000\0224\n\014max_duration\030\006 \001(\0132\031.google."
- + "protobuf.DurationB\003\340A\001\022\026\n\tmax_bytes\030\007 \001("
- + "\003B\003\340A\001\022>\n\005state\030\t \001(\0162*.google.pubsub.v1"
- + ".CloudStorageConfig.StateB\003\340A\003\032\014\n\nTextCo"
- + "nfig\032)\n\nAvroConfig\022\033\n\016write_metadata\030\001 \001"
- + "(\010B\003\340A\001\"u\n\005State\022\025\n\021STATE_UNSPECIFIED\020\000\022"
+ + "\006 \001(\010B\003\340A\001\022\"\n\025service_account_email\030\007 \001("
+ + "\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#\n\037IN_TRANSIT_LOCATION_RESTRIC"
- + "TION\020\004B\017\n\routput_format\"|\n\017ReceivedMessa"
- + "ge\022\023\n\006ack_id\030\001 \001(\tB\003\340A\001\0225\n\007message\030\002 \001(\013"
- + "2\037.google.pubsub.v1.PubsubMessageB\003\340A\001\022\035"
- + "\n\020delivery_attempt\030\003 \001(\005B\003\340A\001\"Z\n\026GetSubs"
- + "criptionRequest\022@\n\014subscription\030\001 \001(\tB*\340"
- + "A\002\372A$\n\"pubsub.googleapis.com/Subscriptio"
- + "n\"\214\001\n\031UpdateSubscriptionRequest\0229\n\014subsc"
- + "ription\030\001 \001(\0132\036.google.pubsub.v1.Subscri"
- + "ptionB\003\340A\002\0224\n\013update_mask\030\002 \001(\0132\032.google"
- + ".protobuf.FieldMaskB\003\340A\002\"\221\001\n\030ListSubscri"
- + "ptionsRequest\022D\n\007project\030\001 \001(\tB3\340A\002\372A-\n+"
- + "cloudresourcemanager.googleapis.com/Proj"
- + "ect\022\026\n\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\npage_toke"
- + "n\030\003 \001(\tB\003\340A\001\"u\n\031ListSubscriptionsRespons"
- + "e\022:\n\rsubscriptions\030\001 \003(\0132\036.google.pubsub"
- + ".v1.SubscriptionB\003\340A\001\022\034\n\017next_page_token"
- + "\030\002 \001(\tB\003\340A\001\"]\n\031DeleteSubscriptionRequest"
- + "\022@\n\014subscription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.g"
- + "oogleapis.com/Subscription\"\223\001\n\027ModifyPus"
- + "hConfigRequest\022@\n\014subscription\030\001 \001(\tB*\340A"
- + "\002\372A$\n\"pubsub.googleapis.com/Subscription"
- + "\0226\n\013push_config\030\002 \001(\0132\034.google.pubsub.v1"
- + ".PushConfigB\003\340A\002\"\215\001\n\013PullRequest\022@\n\014subs"
+ + "T_FOUND\020\003\022\023\n\017SCHEMA_MISMATCH\020\004\022#\n\037IN_TRA"
+ + "NSIT_LOCATION_RESTRICTION\020\005\"\231\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"
+ + "\n \001(\tB\003\340A\001\022K\n\013text_config\030\004 \001(\0132/.google"
+ + ".pubsub.v1.CloudStorageConfig.TextConfig"
+ + "B\003\340A\001H\000\022K\n\013avro_config\030\005 \001(\0132/.google.pu"
+ + "bsub.v1.CloudStorageConfig.AvroConfigB\003\340"
+ + "A\001H\000\0224\n\014max_duration\030\006 \001(\0132\031.google.prot"
+ + "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\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\014PullResponse\022A\n\021received_messages\030\001 "
- + "\003(\0132!.google.pubsub.v1.ReceivedMessageB\003"
- + "\340A\001\"\225\001\n\030ModifyAckDeadlineRequest\022@\n\014subs"
- + "cription\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapi"
- + "s.com/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\022A"
- + "cknowledgeRequest\022@\n\014subscription\030\001 \001(\tB"
- + "*\340A\002\372A$\n\"pubsub.googleapis.com/Subscript"
- + "ion\022\024\n\007ack_ids\030\002 \003(\tB\003\340A\002\"\307\002\n\024StreamingP"
- + "ullRequest\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\001\022$\n\027modify_deadline_se"
- + "conds\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_se"
- + "conds\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_outstanding_bytes\030\010 \001(\003B\003\340A\001\"\236\006\n\025"
- + "StreamingPullResponse\022A\n\021received_messag"
- + "es\030\001 \003(\0132!.google.pubsub.v1.ReceivedMess"
- + "ageB\003\340A\001\022f\n\030acknowledge_confirmation\030\005 \001"
- + "(\0132?.google.pubsub.v1.StreamingPullRespo"
- + "nse.AcknowledgeConfirmationB\003\340A\001\022t\n modi"
- + "fy_ack_deadline_confirmation\030\003 \001(\0132E.goo"
- + "gle.pubsub.v1.StreamingPullResponse.Modi"
- + "fyAckDeadlineConfirmationB\003\340A\001\022d\n\027subscr"
- + "iption_properties\030\004 \001(\0132>.google.pubsub."
- + "v1.StreamingPullResponse.SubscriptionPro"
- + "pertiesB\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_id"
- + "s\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\035ModifyAckDeadlineConfirmation\022\024\n\007"
- + "ack_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\032k\n\026SubscriptionProperties\022*\n\035exa"
- + "ctly_once_delivery_enabled\030\001 \001(\010B\003\340A\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/Snapshot\022@\n\014"
- + "subscription\030\002 \001(\tB*\340A\002\372A$\n\"pubsub.googl"
- + "eapis.com/Subscription\022H\n\006labels\030\003 \003(\01323"
- + ".google.pubsub.v1.CreateSnapshotRequest."
- + "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\"\200\001\n\025UpdateSnapsh"
- + "otRequest\0221\n\010snapshot\030\001 \001(\0132\032.google.pub"
- + "sub.v1.SnapshotB\003\340A\002\0224\n\013update_mask\030\002 \001("
- + "\0132\032.google.protobuf.FieldMaskB\003\340A\002\"\301\002\n\010S"
- + "napshot\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.Ti"
- + "mestampB\003\340A\001\022;\n\006labels\030\004 \003(\0132&.google.pu"
- + "bsub.v1.Snapshot.LabelsEntryB\003\340A\001\032-\n\013Lab"
- + "elsEntry\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\'p"
- + "rojects/{project}/snapshots/{snapshot}\"N"
- + "\n\022GetSnapshotRequest\0228\n\010snapshot\030\001 \001(\tB&"
- + "\340A\002\372A \n\036pubsub.googleapis.com/Snapshot\"\215"
- + "\001\n\024ListSnapshotsRequest\022D\n\007project\030\001 \001(\t"
- + "B3\340A\002\372A-\n+cloudresourcemanager.googleapi"
- + "s.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\"i\n\025ListSnapshotsR"
- + "esponse\0222\n\tsnapshots\030\001 \003(\0132\032.google.pubs"
- + "ub.v1.SnapshotB\003\340A\001\022\034\n\017next_page_token\030\002"
- + " \001(\tB\003\340A\001\"Q\n\025DeleteSnapshotRequest\0228\n\010sn"
- + "apshot\030\001 \001(\tB&\340A\002\372A \n\036pubsub.googleapis."
- + "com/Snapshot\"\306\001\n\013SeekRequest\022@\n\014subscrip"
- + "tion\030\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.co"
- + "m/Subscription\022/\n\004time\030\002 \001(\0132\032.google.pr"
- + "otobuf.TimestampB\003\340A\001H\000\022:\n\010snapshot\030\003 \001("
- + "\tB&\340A\001\372A \n\036pubsub.googleapis.com/Snapsho"
- + "tH\000B\010\n\006target\"\016\n\014SeekResponse2\270\013\n\tPublis"
- + "her\022q\n\013CreateTopic\022\027.google.pubsub.v1.To"
- + "pic\032\027.google.pubsub.v1.Topic\"0\332A\004name\202\323\344"
- + "\223\002#\032\036/v1/{name=projects/*/topics/*}:\001*\022\221"
- + "\001\n\013UpdateTopic\022$.google.pubsub.v1.Update"
- + "TopicRequest\032\027.google.pubsub.v1.Topic\"C\332"
- + "A\021topic,update_mask\202\323\344\223\002)2$/v1/{topic.na"
- + "me=projects/*/topics/*}:\001*\022\223\001\n\007Publish\022 "
- + ".google.pubsub.v1.PublishRequest\032!.googl"
- + "e.pubsub.v1.PublishResponse\"C\332A\016topic,me"
- + "ssages\202\323\344\223\002,\"\'/v1/{topic=projects/*/topi"
- + "cs/*}:publish:\001*\022w\n\010GetTopic\022!.google.pu"
- + "bsub.v1.GetTopicRequest\032\027.google.pubsub."
- + "v1.Topic\"/\332A\005topic\202\323\344\223\002!\022\037/v1/{topic=pro"
- + "jects/*/topics/*}\022\212\001\n\nListTopics\022#.googl"
- + "e.pubsub.v1.ListTopicsRequest\032$.google.p"
- + "ubsub.v1.ListTopicsResponse\"1\332A\007project\202"
- + "\323\344\223\002!\022\037/v1/{project=projects/*}/topics\022\272"
- + "\001\n\026ListTopicSubscriptions\022/.google.pubsu"
- + "b.v1.ListTopicSubscriptionsRequest\0320.goo"
- + "gle.pubsub.v1.ListTopicSubscriptionsResp"
- + "onse\"=\332A\005topic\202\323\344\223\002/\022-/v1/{topic=project"
- + "s/*/topics/*}/subscriptions\022\252\001\n\022ListTopi"
- + "cSnapshots\022+.google.pubsub.v1.ListTopicS"
- + "napshotsRequest\032,.google.pubsub.v1.ListT"
- + "opicSnapshotsResponse\"9\332A\005topic\202\323\344\223\002+\022)/"
- + "v1/{topic=projects/*/topics/*}/snapshots"
- + "\022|\n\013DeleteTopic\022$.google.pubsub.v1.Delet"
- + "eTopicRequest\032\026.google.protobuf.Empty\"/\332"
- + "A\005topic\202\323\344\223\002!*\037/v1/{topic=projects/*/top"
- + "ics/*}\022\255\001\n\022DetachSubscription\022+.google.p"
- + "ubsub.v1.DetachSubscriptionRequest\032,.goo"
- + "gle.pubsub.v1.DetachSubscriptionResponse"
- + "\"<\202\323\344\223\0026\"4/v1/{subscription=projects/*/s"
- + "ubscriptions/*}:detach\032p\312A\025pubsub.google"
- + "apis.com\322AUhttps://www.googleapis.com/au"
- + "th/cloud-platform,https://www.googleapis"
- + ".com/auth/pubsub2\322\025\n\nSubscriber\022\264\001\n\022Crea"
- + "teSubscription\022\036.google.pubsub.v1.Subscr"
- + "iption\032\036.google.pubsub.v1.Subscription\"^"
- + "\332A+name,topic,push_config,ack_deadline_s"
- + "econds\202\323\344\223\002*\032%/v1/{name=projects/*/subsc"
- + "riptions/*}:\001*\022\241\001\n\017GetSubscription\022(.goo"
- + "gle.pubsub.v1.GetSubscriptionRequest\032\036.g"
- + "oogle.pubsub.v1.Subscription\"D\332A\014subscri"
- + "ption\202\323\344\223\002/\022-/v1/{subscription=projects/"
- + "*/subscriptions/*}\022\273\001\n\022UpdateSubscriptio"
- + "n\022+.google.pubsub.v1.UpdateSubscriptionR"
- + "equest\032\036.google.pubsub.v1.Subscription\"X"
- + "\332A\030subscription,update_mask\202\323\344\223\002722/v1/{"
- + "subscription.name=projects/*/subscriptio"
- + "ns/*}:\001*\022\246\001\n\021ListSubscriptions\022*.google."
- + "pubsub.v1.ListSubscriptionsRequest\032+.goo"
- + "gle.pubsub.v1.ListSubscriptionsResponse\""
- + "8\332A\007project\202\323\344\223\002(\022&/v1/{project=projects"
- + "/*}/subscriptions\022\237\001\n\022DeleteSubscription"
- + "\022+.google.pubsub.v1.DeleteSubscriptionRe"
- + "quest\032\026.google.protobuf.Empty\"D\332A\014subscr"
- + "iption\202\323\344\223\002/*-/v1/{subscription=projects"
- + "/*/subscriptions/*}\022\317\001\n\021ModifyAckDeadlin"
- + "e\022*.google.pubsub.v1.ModifyAckDeadlineRe"
- + "quest\032\026.google.protobuf.Empty\"v\332A)subscr"
- + "iption,ack_ids,ack_deadline_seconds\202\323\344\223\002"
- + "D\"?/v1/{subscription=projects/*/subscrip"
- + "tions/*}:modifyAckDeadline:\001*\022\250\001\n\013Acknow"
- + "ledge\022$.google.pubsub.v1.AcknowledgeRequ"
- + "est\032\026.google.protobuf.Empty\"[\332A\024subscrip"
- + "tion,ack_ids\202\323\344\223\002>\"9/v1/{subscription=pr"
- + "ojects/*/subscriptions/*}:acknowledge:\001*"
- + "\022\320\001\n\004Pull\022\035.google.pubsub.v1.PullRequest"
- + "\032\036.google.pubsub.v1.PullResponse\"\210\001\332A,su"
- + "bscription,return_immediately,max_messag"
- + "es\332A\031subscription,max_messages\202\323\344\223\0027\"2/v"
- + "1/{subscription=projects/*/subscriptions"
- + "/*}:pull:\001*\022f\n\rStreamingPull\022&.google.pu"
- + "bsub.v1.StreamingPullRequest\032\'.google.pu"
- + "bsub.v1.StreamingPullResponse\"\000(\0010\001\022\273\001\n\020"
- + "ModifyPushConfig\022).google.pubsub.v1.Modi"
- + "fyPushConfigRequest\032\026.google.protobuf.Em"
- + "pty\"d\332A\030subscription,push_config\202\323\344\223\002C\">"
- + "/v1/{subscription=projects/*/subscriptio"
- + "ns/*}:modifyPushConfig:\001*\022\211\001\n\013GetSnapsho"
- + "t\022$.google.pubsub.v1.GetSnapshotRequest\032"
- + "\032.google.pubsub.v1.Snapshot\"8\332A\010snapshot"
- + "\202\323\344\223\002\'\022%/v1/{snapshot=projects/*/snapsho"
- + "ts/*}\022\226\001\n\rListSnapshots\022&.google.pubsub."
- + "v1.ListSnapshotsRequest\032\'.google.pubsub."
- + "v1.ListSnapshotsResponse\"4\332A\007project\202\323\344\223"
- + "\002$\022\"/v1/{project=projects/*}/snapshots\022\227"
- + "\001\n\016CreateSnapshot\022\'.google.pubsub.v1.Cre"
- + "ateSnapshotRequest\032\032.google.pubsub.v1.Sn"
- + "apshot\"@\332A\021name,subscription\202\323\344\223\002&\032!/v1/"
- + "{name=projects/*/snapshots/*}:\001*\022\243\001\n\016Upd"
- + "ateSnapshot\022\'.google.pubsub.v1.UpdateSna"
- + "pshotRequest\032\032.google.pubsub.v1.Snapshot"
- + "\"L\332A\024snapshot,update_mask\202\323\344\223\002/2*/v1/{sn"
- + "apshot.name=projects/*/snapshots/*}:\001*\022\213"
- + "\001\n\016DeleteSnapshot\022\'.google.pubsub.v1.Del"
- + "eteSnapshotRequest\032\026.google.protobuf.Emp"
- + "ty\"8\332A\010snapshot\202\323\344\223\002\'*%/v1/{snapshot=pro"
- + "jects/*/snapshots/*}\022\204\001\n\004Seek\022\035.google.p"
- + "ubsub.v1.SeekRequest\032\036.google.pubsub.v1."
- + "SeekResponse\"=\202\323\344\223\0027\"2/v1/{subscription="
- + "projects/*/subscriptions/*}:seek:\001*\032p\312A\025"
- + "pubsub.googleapis.com\322AUhttps://www.goog"
- + "leapis.com/auth/cloud-platform,https://w"
- + "ww.googleapis.com/auth/pubsubB\252\001\n\024com.go"
- + "ogle.pubsub.v1B\013PubsubProtoP\001Z2cloud.goo"
- + "gle.com/go/pubsub/apiv1/pubsubpb;pubsubp"
- + "b\370\001\001\252\002\026Google.Cloud.PubSub.V1\312\002\026Google\\C"
- + "loud\\PubSub\\V1\352\002\031Google::Cloud::PubSub::"
- + "V1b\006proto3"
+ + "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"
+ + "(\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"
+ + "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"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -953,6 +955,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
"DropUnknownFields",
"State",
"UseTableSchema",
+ "ServiceAccountEmail",
});
internal_static_google_pubsub_v1_CloudStorageConfig_descriptor =
getDescriptor().getMessageTypes().get(24);
@@ -969,6 +972,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
"MaxDuration",
"MaxBytes",
"State",
+ "ServiceAccountEmail",
"OutputFormat",
});
internal_static_google_pubsub_v1_CloudStorageConfig_TextConfig_descriptor =
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 9d0f93c99..5341666eb 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() {
*
*
* @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
- * google/pubsub/v1/pubsub.proto;l=1363
+ * google/pubsub/v1/pubsub.proto;l=1379
* @return The returnImmediately.
*/
@java.lang.Override
@@ -688,7 +688,7 @@ public Builder setSubscriptionBytes(com.google.protobuf.ByteString value) {
*
*
* @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
- * google/pubsub/v1/pubsub.proto;l=1363
+ * google/pubsub/v1/pubsub.proto;l=1379
* @return The returnImmediately.
*/
@java.lang.Override
@@ -714,7 +714,7 @@ public boolean getReturnImmediately() {
*
*
* @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
- * google/pubsub/v1/pubsub.proto;l=1363
+ * google/pubsub/v1/pubsub.proto;l=1379
* @param value The returnImmediately to set.
* @return This builder for chaining.
*/
@@ -744,7 +744,7 @@ public Builder setReturnImmediately(boolean value) {
*
*
* @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
- * google/pubsub/v1/pubsub.proto;l=1363
+ * google/pubsub/v1/pubsub.proto;l=1379
* @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 08a7576aa..2dc2208a4 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
*
*
* @deprecated google.pubsub.v1.PullRequest.return_immediately is deprecated. See
- * google/pubsub/v1/pubsub.proto;l=1363
+ * google/pubsub/v1/pubsub.proto;l=1379
* @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 2e606060d..8546dacf9 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
@@ -1141,6 +1141,14 @@ message BigQueryConfig {
// write to in BigQuery. `use_table_schema` and `use_topic_schema` cannot be
// enabled at the same time.
bool use_table_schema = 6 [(google.api.field_behavior) = OPTIONAL];
+
+ // Optional. The service account to use to write to BigQuery. The subscription
+ // creator or updater that specifies this field must have
+ // `iam.serviceAccounts.actAs` permission on the service account. If not
+ // specified, the Pub/Sub [service
+ // agent](https://cloud.google.com/iam/docs/service-agents),
+ // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ string service_account_email = 7 [(google.api.field_behavior) = OPTIONAL];
}
// Configuration for a Cloud Storage subscription.
@@ -1227,6 +1235,14 @@ message CloudStorageConfig {
// Output only. An output-only field that indicates whether or not the
// subscription can receive messages.
State state = 9 [(google.api.field_behavior) = OUTPUT_ONLY];
+
+ // Optional. The service account to use to write to Cloud Storage. The
+ // subscription creator or updater that specifies this field must have
+ // `iam.serviceAccounts.actAs` permission on the service account. If not
+ // specified, the Pub/Sub
+ // [service agent](https://cloud.google.com/iam/docs/service-agents),
+ // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
+ string service_account_email = 11 [(google.api.field_behavior) = OPTIONAL];
}
// A message and its corresponding acknowledgment ID.