googleapis · mpeddada1 · Oct 3, 2025 · Sep 30, 2025 · Sep 30, 2025 · Oct 1, 2025
@@ -25,7 +25,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [11, 17, 21, 24]
+        java: [11, 17, 21, 25]
     steps:
     - uses: actions/checkout@v4
     - uses: actions/setup-java@v4

@@ -37,7 +37,7 @@ jobs:
       with:
         fetch-depth: 0
         token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }}
-    - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.2
+    - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.3
       if: env.SHOULD_RUN == 'true'
       with:
         base_ref: ${{ github.base_ref }}

@@ -26,7 +26,7 @@ jobs:
       # the branch into which the pull request is merged
       base_branch: main
     steps:
-    - uses: actions/checkout@v5
+    - uses: actions/checkout@v4
       with:
         fetch-depth: 0
         token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }}

@@ -3,7 +3,7 @@
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
   key: "TRAMPOLINE_IMAGE"
-  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
+  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.52.3" # {x-version-update:google-cloud-shared-dependencies:current}
 }
 
 env_vars: {

@@ -3,7 +3,7 @@
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
   key: "TRAMPOLINE_IMAGE"
-  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
+  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.52.3" # {x-version-update:google-cloud-shared-dependencies:current}
 }
 
 env_vars: {

@@ -3,7 +3,7 @@
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
   key: "TRAMPOLINE_IMAGE"
-  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
+  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.52.3" # {x-version-update:google-cloud-shared-dependencies:current}
 }
 
 env_vars: {

@@ -43,15 +43,15 @@ If you are using Maven without the BOM, add this to your dependencies:
 <dependency>
   <groupId>com.google.cloud</groupId>
   <artifactId>google-cloud-pubsub</artifactId>
-  <version>1.141.4</version>
+  <version>1.141.5</version>
 </dependency>
 
 ```
 
 If you are using Gradle 5.x or later, add this to your dependencies:
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:26.68.0')
+implementation platform('com.google.cloud:libraries-bom:26.69.0')
 
 implementation 'com.google.cloud:google-cloud-pubsub'
 ```

@@ -1,6 +1,6 @@
-gapic_generator_version: 2.62.2
-googleapis_commitish: 31b413bc4feb03f6849c718048c2b9998561b5fa
-libraries_bom_version: 26.68.0
+gapic_generator_version: 2.62.3
+googleapis_commitish: 9070e63a1f574261c153ef6e94afc55677200337
+libraries_bom_version: 26.69.0
 libraries:
   - api_shortname: pubsub
     name_pretty: Cloud Pub/Sub

@@ -2406,6 +2406,7 @@ public final UnaryCallable<PullRequest, PullResponse> pullCallable() {
    *           .setClientId("clientId908408390")
    *           .setMaxOutstandingMessages(-1315266996)
    *           .setMaxOutstandingBytes(-2103098517)
+   *           .setProtocolVersion(-1161610703)
    *           .build();
    *   bidiStream.send(request);
    *   for (StreamingPullResponse response : bidiStream) {

@@ -1074,6 +1074,7 @@ public void streamingPullTest() throws Exception {
             .setClientId("clientId908408390")
             .setMaxOutstandingMessages(-1315266996)
             .setMaxOutstandingBytes(-2103098517)
+            .setProtocolVersion(-1161610703)
             .build();
 
     MockStreamObserver<StreamingPullResponse> responseObserver = new MockStreamObserver<>();
@@ -1105,6 +1106,7 @@ public void streamingPullExceptionTest() throws Exception {
             .setClientId("clientId908408390")
             .setMaxOutstandingMessages(-1315266996)
             .setMaxOutstandingBytes(-2103098517)
+            .setProtocolVersion(-1161610703)
             .build();
 
     MockStreamObserver<StreamingPullResponse> responseObserver = new MockStreamObserver<>();

@@ -531,6 +531,27 @@ public long getMaxOutstandingBytes() {
     return maxOutstandingBytes_;
   }
 
+  public static final int PROTOCOL_VERSION_FIELD_NUMBER = 10;
+  private long protocolVersion_ = 0L;
+
+  /**
+   *
+   *
+   * <pre>
+   * Optional. The protocol version used by the client. This property can only
+   * be set on the initial StreamingPullRequest. If it is set on a subsequent
+   * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+   * </pre>
+   *
+   * <code>int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL];</code>
+   *
+   * @return The protocolVersion.
+   */
+  @java.lang.Override
+  public long getProtocolVersion() {
+    return protocolVersion_;
+  }
+
   private byte memoizedIsInitialized = -1;
 
   @java.lang.Override
@@ -575,6 +596,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     if (maxOutstandingBytes_ != 0L) {
       output.writeInt64(8, maxOutstandingBytes_);
     }
+    if (protocolVersion_ != 0L) {
+      output.writeInt64(10, protocolVersion_);
+    }
     getUnknownFields().writeTo(output);
   }
 
@@ -629,6 +653,9 @@ public int getSerializedSize() {
     if (maxOutstandingBytes_ != 0L) {
       size += com.google.protobuf.CodedOutputStream.computeInt64Size(8, maxOutstandingBytes_);
     }
+    if (protocolVersion_ != 0L) {
+      size += com.google.protobuf.CodedOutputStream.computeInt64Size(10, protocolVersion_);
+    }
     size += getUnknownFields().getSerializedSize();
     memoizedSize = size;
     return size;
@@ -653,6 +680,7 @@ public boolean equals(final java.lang.Object obj) {
     if (!getClientId().equals(other.getClientId())) return false;
     if (getMaxOutstandingMessages() != other.getMaxOutstandingMessages()) return false;
     if (getMaxOutstandingBytes() != other.getMaxOutstandingBytes()) return false;
+    if (getProtocolVersion() != other.getProtocolVersion()) return false;
     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
     return true;
   }
@@ -686,6 +714,8 @@ public int hashCode() {
     hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxOutstandingMessages());
     hash = (37 * hash) + MAX_OUTSTANDING_BYTES_FIELD_NUMBER;
     hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxOutstandingBytes());
+    hash = (37 * hash) + PROTOCOL_VERSION_FIELD_NUMBER;
+    hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getProtocolVersion());
     hash = (29 * hash) + getUnknownFields().hashCode();
     memoizedHashCode = hash;
     return hash;
@@ -836,6 +866,7 @@ public Builder clear() {
       clientId_ = "";
       maxOutstandingMessages_ = 0L;
       maxOutstandingBytes_ = 0L;
+      protocolVersion_ = 0L;
       return this;
     }
 
@@ -899,6 +930,9 @@ private void buildPartial0(com.google.pubsub.v1.StreamingPullRequest result) {
       if (((from_bitField0_ & 0x00000080) != 0)) {
         result.maxOutstandingBytes_ = maxOutstandingBytes_;
       }
+      if (((from_bitField0_ & 0x00000100) != 0)) {
+        result.protocolVersion_ = protocolVersion_;
+      }
     }
 
     @java.lang.Override
@@ -996,6 +1030,9 @@ public Builder mergeFrom(com.google.pubsub.v1.StreamingPullRequest other) {
       if (other.getMaxOutstandingBytes() != 0L) {
         setMaxOutstandingBytes(other.getMaxOutstandingBytes());
       }
+      if (other.getProtocolVersion() != 0L) {
+        setProtocolVersion(other.getProtocolVersion());
+      }
       this.mergeUnknownFields(other.getUnknownFields());
       onChanged();
       return this;
@@ -1084,6 +1121,12 @@ public Builder mergeFrom(
                 bitField0_ |= 0x00000080;
                 break;
               } // case 64
+            case 80:
+              {
+                protocolVersion_ = input.readInt64();
+                bitField0_ |= 0x00000100;
+                break;
+              } // case 80
             default:
               {
                 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -2262,6 +2305,68 @@ public Builder clearMaxOutstandingBytes() {
       return this;
     }
 
+    private long protocolVersion_;
+
+    /**
+     *
+     *
+     * <pre>
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     * </pre>
+     *
+     * <code>int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL];</code>
+     *
+     * @return The protocolVersion.
+     */
+    @java.lang.Override
+    public long getProtocolVersion() {
+      return protocolVersion_;
+    }
+
+    /**
+     *
+     *
+     * <pre>
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     * </pre>
+     *
+     * <code>int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL];</code>
+     *
+     * @param value The protocolVersion to set.
+     * @return This builder for chaining.
+     */
+    public Builder setProtocolVersion(long value) {
+
+      protocolVersion_ = value;
+      bitField0_ |= 0x00000100;
+      onChanged();
+      return this;
+    }
+
+    /**
+     *
+     *
+     * <pre>
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     * </pre>
+     *
+     * <code>int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL];</code>
+     *
+     * @return This builder for chaining.
+     */
+    public Builder clearProtocolVersion() {
+      bitField0_ = (bitField0_ & ~0x00000100);
+      protocolVersion_ = 0L;
+      onChanged();
+      return this;
+    }
+
     @java.lang.Override
     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
       return super.setUnknownFields(unknownFields);

@@ -370,4 +370,19 @@ public interface StreamingPullRequestOrBuilder
    * @return The maxOutstandingBytes.
    */
   long getMaxOutstandingBytes();
+
+  /**
+   *
+   *
+   * <pre>
+   * Optional. The protocol version used by the client. This property can only
+   * be set on the initial StreamingPullRequest. If it is set on a subsequent
+   * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+   * </pre>
+   *
+   * <code>int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL];</code>
+   *
+   * @return The protocolVersion.
+   */
+  long getProtocolVersion();
 }
@@ -2124,6 +2124,11 @@ message StreamingPullRequest {
   // set on a subsequent request, the stream will be aborted with status
   // `INVALID_ARGUMENT`.
   int64 max_outstanding_bytes = 8 [(google.api.field_behavior) = OPTIONAL];
+
+  // Optional. The protocol version used by the client. This property can only
+  // be set on the initial StreamingPullRequest. If it is set on a subsequent
+  // request, the stream will be aborted with status `INVALID_ARGUMENT`.
+  int64 protocol_version = 10 [(google.api.field_behavior) = OPTIONAL];
 }
 
 // Response for the `StreamingPull` method. This response is used to stream