The GitHub Actions job "CI" on pekko-connectors.git/main has failed. Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run: fde163d634dec7275979d619423e6f769b725f63 / Haruhiko Nishi <[email protected]> Google Cloud Pub/Sub gRPC: subscribe() must not echo initial-only StreamingPullRequest fields on keepalive ticks (#1625) * Google Cloud Pub/Sub gRPC: subscribe() must not echo initial-only StreamingPullRequest fields on keepalive ticks * `subscribe(...)` was clearing only `subscription` and `streamAckDeadlineSeconds` on the keepalive request, leaving `clientId`, `maxOutstandingMessages`, and `maxOutstandingBytes` from the initial one. Pub/Sub rejects those three on subsequent requests with `INVALID_ARGUMENT`, so any caller setting `maxOutstandingMessages` loses the whole stream about a second after start. Fix is one line on each DSL: use `StreamingPullRequest.defaultInstance` (Scala) / `getDefaultInstance` (Java) for the keepalive. Clears every initial-only field at once and stays safe if the proto grows more later. * Google Cloud Pub/Sub gRPC: replace Thread.sleep with eventually in the keepalive-tick test `Thread.sleep(500)` replaced with `eventually(timeout(5.s), interval(50.ms))` polling the captured queue. * Google Cloud Pub/Sub gRPC: use top-level imports in the test stub Dropped `scaladsl.`/`pekko.NotUsed` prefixes. Report URL: https://github.com/apache/pekko-connectors/actions/runs/25794648652 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
