diff --git a/pubsublite/ps/settings.go b/pubsublite/ps/settings.go index f8a9629df7c1..b40d687d7d6a 100644 --- a/pubsublite/ps/settings.go +++ b/pubsublite/ps/settings.go @@ -180,6 +180,7 @@ func (s *ReceiveSettings) toWireSettings() wire.ReceiveSettings { MaxOutstandingMessages: s.MaxOutstandingMessages, MaxOutstandingBytes: s.MaxOutstandingBytes, Timeout: s.Timeout, + Partitions: s.Partitions, Framework: wire.FrameworkCloudPubSubShim, } }