fix(pubsublite): disable grpc stream retries (#5019)

Disable grpc-go automatically recreating streams. The Pub/Sub Lite library must reinitialize state when a new stream instance is created.

pubsublite/internal/wire/rpc.go

@@ -193,9 +193,13 @@ func defaultClientOptions(region string) []option.ClientOption {
 }
 
 func streamClientOptions(region string) []option.ClientOption {
-	// To ensure most users don't hit the limit of 100 streams per connection, if
-	// they have a high number of topic partitions.
-	return append(defaultClientOptions(region), option.WithGRPCConnectionPool(8))
+	return append(defaultClientOptions(region),
+		// To ensure most users don't hit the limit of 100 streams per connection, if
+		// they have a high number of topic partitions.
+		option.WithGRPCConnectionPool(8),
+		// Stream reconnections must be handled here in order to reinitialize state,
+		// rather than in grpc-go.
+		option.WithGRPCDialOption(grpc.WithDisableRetry()))
 }
 
 // NewAdminClient creates a new gapic AdminClient for a region.