Skip to content

Conversation

@tmdiep
Copy link
Contributor

@tmdiep tmdiep commented Feb 1, 2022

Mitigates hanging streams by detecting idle streams and reconnecting after a timeout (default 10min for partition assignment streams, 2min for all others).

The StreamIdleTimer is restarted when the client receives a response on the stream. The stream is reinitialized when the timeout expires. For publish and commit streams, the timeout will still expire even if there is no user activity.

Internal: cl/422650400 and subsequent fixes.

@tmdiep tmdiep requested review from a team as code owners February 1, 2022 02:06
@product-auto-label product-auto-label bot added the api: pubsublite Issues related to the googleapis/java-pubsublite API. label Feb 1, 2022
@tmdiep tmdiep added the owlbot:run Add this label to trigger the Owlbot post processor. label Feb 1, 2022
@gcf-owl-bot gcf-owl-bot bot removed the owlbot:run Add this label to trigger the Owlbot post processor. label Feb 1, 2022
@tmdiep tmdiep changed the title fix: mitigate gRPC stream connection issues fix: Mitigate gRPC stream connection issues Feb 3, 2022
@tmdiep tmdiep merged commit f3678b7 into googleapis:main Feb 4, 2022
@tmdiep tmdiep deleted the idle_streams branch February 4, 2022 01:51
gcf-merge-on-green bot pushed a commit that referenced this pull request Feb 4, 2022
🤖 I have created a release *beep* *boop*
---


### [1.4.9](v1.4.8...v1.4.9) (2022-02-04)


### Bug Fixes

* Ensure messages are delivered in order ([#1031](#1031)) ([a8a969e](a8a969e))
* mitigate gRPC stream connection issues ([#1038](#1038)) ([f3678b7](f3678b7))
* Reinitialize streams in an unbounded executor ([#1027](#1027)) ([6377c1d](6377c1d))


### Documentation

* Update comments for regional topics ([#967](#967)) ([7220439](7220439))


### Dependencies

* update dependency com.google.cloud:google-cloud-bom to v0.166.0 ([#1017](#1017)) ([03ae03a](03ae03a))
* update dependency com.google.cloud:google-cloud-pubsub to v1.115.1 ([#1014](#1014)) ([59e74c9](59e74c9))
* update dependency com.google.cloud:google-cloud-pubsub to v1.115.2 ([#1041](#1041)) ([1f46ca9](1f46ca9))
* update dependency com.google.cloud:google-cloud-shared-dependencies to v2.7.0 ([#1037](#1037)) ([15d4215](15d4215))
* update dependency com.google.errorprone:error_prone_annotations to v2.11.0 ([#1032](#1032)) ([677b96b](677b96b))
* update dependency com.google.errorprone:error_prone_core to v2.11.0 ([#1033](#1033)) ([088cc62](088cc62))
* update dependency org.checkerframework:checker-qual to v3.21.1 ([#1015](#1015)) ([ffa1f0b](ffa1f0b))

---
This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please).
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

api: pubsublite Issues related to the googleapis/java-pubsublite API.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants