diff --git a/google/cloud/pubsublite/v1/admin.proto b/google/cloud/pubsublite/v1/admin.proto
index fb32fa0f..a64ac19d 100644
--- a/google/cloud/pubsublite/v1/admin.proto
+++ b/google/cloud/pubsublite/v1/admin.proto
@@ -24,16 +24,20 @@ import "google/cloud/pubsublite/v1/common.proto";
 import "google/protobuf/empty.proto";
 import "google/protobuf/field_mask.proto";
 
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "AdminProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // The service that a client application uses to manage topics and
 // subscriptions, such creating, listing, and deleting topics and subscriptions.
 service AdminService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Creates a new topic.
   rpc CreateTopic(CreateTopicRequest) returns (Topic) {
@@ -86,7 +90,8 @@ service AdminService {
   }
 
   // Lists the subscriptions attached to the specified topic.
-  rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest) returns (ListTopicSubscriptionsResponse) {
+  rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest)
+      returns (ListTopicSubscriptionsResponse) {
     option (google.api.http) = {
       get: "/v1/admin/{name=projects/*/locations/*/topics/*}/subscriptions"
     };
@@ -99,7 +104,8 @@ service AdminService {
       post: "/v1/admin/{parent=projects/*/locations/*}/subscriptions"
       body: "subscription"
     };
-    option (google.api.method_signature) = "parent,subscription,subscription_id";
+    option (google.api.method_signature) =
+        "parent,subscription,subscription_id";
   }
 
   // Returns the subscription configuration.
@@ -111,7 +117,8 @@ service AdminService {
   }
 
   // Returns the list of subscriptions for the given project.
-  rpc ListSubscriptions(ListSubscriptionsRequest) returns (ListSubscriptionsResponse) {
+  rpc ListSubscriptions(ListSubscriptionsRequest)
+      returns (ListSubscriptionsResponse) {
     option (google.api.http) = {
       get: "/v1/admin/{parent=projects/*/locations/*}/subscriptions"
     };
@@ -128,7 +135,8 @@ service AdminService {
   }
 
   // Deletes the specified subscription.
-  rpc DeleteSubscription(DeleteSubscriptionRequest) returns (google.protobuf.Empty) {
+  rpc DeleteSubscription(DeleteSubscriptionRequest)
+      returns (google.protobuf.Empty) {
     option (google.api.http) = {
       delete: "/v1/admin/{name=projects/*/locations/*/subscriptions/*}"
     };
@@ -147,11 +155,12 @@ message CreateTopicRequest {
     }
   ];
 
-  // Required. Configuration of the topic to create. Its `name` field is ignored.
+  // Required. Configuration of the topic to create. Its `name` field is
+  // ignored.
   Topic topic = 2 [(google.api.field_behavior) = REQUIRED];
 
-  // Required. The ID to use for the topic, which will become the final component of
-  // the topic's name.
+  // Required. The ID to use for the topic, which will become the final
+  // component of the topic's name.
   //
   // This value is structured like: `my-topic-name`.
   string topic_id = 3 [(google.api.field_behavior) = REQUIRED];
@@ -226,7 +235,8 @@ message UpdateTopicRequest {
   Topic topic = 1 [(google.api.field_behavior) = REQUIRED];
 
   // Required. A mask specifying the topic fields to change.
-  google.protobuf.FieldMask update_mask = 2 [(google.api.field_behavior) = REQUIRED];
+  google.protobuf.FieldMask update_mask = 2
+      [(google.api.field_behavior) = REQUIRED];
 }
 
 // Request for DeleteTopic.
@@ -285,11 +295,12 @@ message CreateSubscriptionRequest {
     }
   ];
 
-  // Required. Configuration of the subscription to create. Its `name` field is ignored.
+  // Required. Configuration of the subscription to create. Its `name` field is
+  // ignored.
   Subscription subscription = 2 [(google.api.field_behavior) = REQUIRED];
 
-  // Required. The ID to use for the subscription, which will become the final component
-  // of the subscription's name.
+  // Required. The ID to use for the subscription, which will become the final
+  // component of the subscription's name.
   //
   // This value is structured like: `my-sub-name`.
   string subscription_id = 3 [(google.api.field_behavior) = REQUIRED];
@@ -348,7 +359,8 @@ message UpdateSubscriptionRequest {
   Subscription subscription = 1 [(google.api.field_behavior) = REQUIRED];
 
   // Required. A mask specifying the subscription fields to change.
-  google.protobuf.FieldMask update_mask = 2 [(google.api.field_behavior) = REQUIRED];
+  google.protobuf.FieldMask update_mask = 2
+      [(google.api.field_behavior) = REQUIRED];
 }
 
 // Request for DeleteSubscription.
diff --git a/google/cloud/pubsublite/v1/common.proto b/google/cloud/pubsublite/v1/common.proto
index 2d5400c0..485d0ac2 100644
--- a/google/cloud/pubsublite/v1/common.proto
+++ b/google/cloud/pubsublite/v1/common.proto
@@ -21,10 +21,13 @@ import "google/protobuf/duration.proto";
 import "google/protobuf/timestamp.proto";
 
 option cc_enable_arenas = true;
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "CommonProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // The values associated with a key of an attribute.
 message AttributeValues {
@@ -177,8 +180,8 @@ message Subscription {
   // Structured like:
   // projects/{project_number}/locations/{location}/topics/{topic_id}
   string topic = 2 [(google.api.resource_reference) = {
-                      type: "pubsublite.googleapis.com/Topic"
-                    }];
+    type: "pubsublite.googleapis.com/Topic"
+  }];
 
   // The settings for this subscription's message delivery.
   DeliveryConfig delivery_config = 3;
diff --git a/google/cloud/pubsublite/v1/cursor.proto b/google/cloud/pubsublite/v1/cursor.proto
index 3ab9b763..7bbaaaf9 100644
--- a/google/cloud/pubsublite/v1/cursor.proto
+++ b/google/cloud/pubsublite/v1/cursor.proto
@@ -23,28 +23,32 @@ import "google/api/resource.proto";
 import "google/cloud/pubsublite/v1/common.proto";
 
 option cc_enable_arenas = true;
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "CursorProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // The service that a subscriber client application uses to manage committed
 // cursors while receiving messsages. A cursor represents a subscriber's
 // progress within a topic partition for a given subscription.
 service CursorService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Establishes a stream with the server for managing committed cursors.
-  rpc StreamingCommitCursor(stream StreamingCommitCursorRequest) returns (stream StreamingCommitCursorResponse) {
-  }
+  rpc StreamingCommitCursor(stream StreamingCommitCursorRequest)
+      returns (stream StreamingCommitCursorResponse) {}
 
   // Updates the committed cursor.
-  rpc CommitCursor(CommitCursorRequest) returns (CommitCursorResponse) {
-  }
+  rpc CommitCursor(CommitCursorRequest) returns (CommitCursorResponse) {}
 
   // Returns all committed cursor information for a subscription.
-  rpc ListPartitionCursors(ListPartitionCursorsRequest) returns (ListPartitionCursorsResponse) {
+  rpc ListPartitionCursors(ListPartitionCursorsRequest)
+      returns (ListPartitionCursorsResponse) {
     option (google.api.http) = {
       get: "/v1/cursor/{parent=projects/*/locations/*/subscriptions/*}/cursors"
     };
@@ -65,9 +69,7 @@ message InitialCommitCursorRequest {
 }
 
 // Response to an InitialCommitCursorRequest.
-message InitialCommitCursorResponse {
-
-}
+message InitialCommitCursorResponse {}
 
 // Streaming request to update the committed cursor. Subsequent
 // SequencedCommitCursorRequests override outstanding ones.
@@ -122,9 +124,7 @@ message CommitCursorRequest {
 }
 
 // Response for CommitCursor.
-message CommitCursorResponse {
-
-}
+message CommitCursorResponse {}
 
 // Request for ListPartitionCursors.
 message ListPartitionCursorsRequest {
diff --git a/google/cloud/pubsublite/v1/publisher.proto b/google/cloud/pubsublite/v1/publisher.proto
index bce6df00..7a648e92 100644
--- a/google/cloud/pubsublite/v1/publisher.proto
+++ b/google/cloud/pubsublite/v1/publisher.proto
@@ -16,14 +16,17 @@ syntax = "proto3";
 
 package google.cloud.pubsublite.v1;
 
-import "google/cloud/pubsublite/v1/common.proto";
 import "google/api/client.proto";
+import "google/cloud/pubsublite/v1/common.proto";
 
 option cc_enable_arenas = true;
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "PublisherProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // The service that a publisher client application uses to publish messages to
 // topics. Published messages are retained by the service for the duration of
@@ -31,7 +34,8 @@ option java_package = "com.google.cloud.pubsublite.proto";
 // to subscriber clients upon request (via the `SubscriberService`).
 service PublisherService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Establishes a stream with the server for publishing messages. Once the
   // stream is initialized, the client publishes messages by sending publish
@@ -40,8 +44,7 @@ service PublisherService {
   // were sent. Note that multiple PublishRequests can be in flight
   // simultaneously, but they will be processed by the server in the order that
   // they are sent by the client on a given stream.
-  rpc Publish(stream PublishRequest) returns (stream PublishResponse) {
-  }
+  rpc Publish(stream PublishRequest) returns (stream PublishResponse) {}
 }
 
 // The first request that must be sent on a newly-opened stream.
@@ -56,9 +59,7 @@ message InitialPublishRequest {
 }
 
 // Response to an InitialPublishRequest.
-message InitialPublishResponse {
-
-}
+message InitialPublishResponse {}
 
 // Request to publish messages to the topic.
 message MessagePublishRequest {
diff --git a/google/cloud/pubsublite/v1/subscriber.proto b/google/cloud/pubsublite/v1/subscriber.proto
index e0cc0fa4..80c50236 100644
--- a/google/cloud/pubsublite/v1/subscriber.proto
+++ b/google/cloud/pubsublite/v1/subscriber.proto
@@ -16,31 +16,35 @@ syntax = "proto3";
 
 package google.cloud.pubsublite.v1;
 
-import "google/cloud/pubsublite/v1/common.proto";
 import "google/api/client.proto";
+import "google/cloud/pubsublite/v1/common.proto";
 
 option cc_enable_arenas = true;
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "SubscriberProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // The service that a subscriber client application uses to receive messages
 // from subscriptions.
 service SubscriberService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Establishes a stream with the server for receiving messages.
-  rpc Subscribe(stream SubscribeRequest) returns (stream SubscribeResponse) {
-  }
+  rpc Subscribe(stream SubscribeRequest) returns (stream SubscribeResponse) {}
 }
 
 // The service that a subscriber client application uses to determine which
 // partitions it should connect to.
 service PartitionAssignmentService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Assign partitions for this client to handle for the specified subscription.
   //
@@ -49,8 +53,8 @@ service PartitionAssignmentService {
   // outstanding on the stream at a time.
   // The client should send a PartitionAssignmentAck after updating the
   // partitions it is connected to to reflect the new assignment.
-  rpc AssignPartitions(stream PartitionAssignmentRequest) returns (stream PartitionAssignment) {
-  }
+  rpc AssignPartitions(stream PartitionAssignmentRequest)
+      returns (stream PartitionAssignment) {}
 }
 
 // The first request that must be sent on a newly-opened stream. The client must
@@ -190,9 +194,7 @@ message PartitionAssignment {
 // partitions may remain unassigned for a period of time until the
 // client is known to be inactive, after which time the server will break the
 // stream.
-message PartitionAssignmentAck {
-
-}
+message PartitionAssignmentAck {}
 
 // A request on the PartitionAssignment stream.
 message PartitionAssignmentRequest {
diff --git a/google/cloud/pubsublite/v1/topic_stats.proto b/google/cloud/pubsublite/v1/topic_stats.proto
index 3ff3f82c..80bf2146 100644
--- a/google/cloud/pubsublite/v1/topic_stats.proto
+++ b/google/cloud/pubsublite/v1/topic_stats.proto
@@ -17,25 +17,30 @@ syntax = "proto3";
 package google.cloud.pubsublite.v1;
 
 import "google/api/annotations.proto";
+import "google/api/client.proto";
 import "google/api/field_behavior.proto";
 import "google/api/resource.proto";
 import "google/cloud/pubsublite/v1/common.proto";
 import "google/protobuf/timestamp.proto";
-import "google/api/client.proto";
 
+option csharp_namespace = "Google.Cloud.PubSubLite.V1";
 option go_package = "google.golang.org/genproto/googleapis/cloud/pubsublite/v1;pubsublite";
 option java_multiple_files = true;
 option java_outer_classname = "TopicStatsProto";
 option java_package = "com.google.cloud.pubsublite.proto";
+option php_namespace = "Google\\Cloud\\PubSubLite\\V1";
+option ruby_package = "Google::Cloud::PubSubLite::V1";
 
 // This service allows users to get stats about messages in their topic.
 service TopicStatsService {
   option (google.api.default_host) = "pubsublite.googleapis.com";
-  option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+  option (google.api.oauth_scopes) =
+      "https://www.googleapis.com/auth/cloud-platform";
 
   // Compute statistics about a range of messages in a given topic and
   // partition.
-  rpc ComputeMessageStats(ComputeMessageStatsRequest) returns (ComputeMessageStatsResponse) {
+  rpc ComputeMessageStats(ComputeMessageStatsRequest)
+      returns (ComputeMessageStatsResponse) {
     option (google.api.http) = {
       post: "/v1/topicStats/{topic=projects/*/locations/*/topics/*}:computeMessageStats"
       body: "*"