From dd148f6c7898215460a535a3a68a491315ecfd1d Mon Sep 17 00:00:00 2001 From: tmdiep Date: Fri, 27 Nov 2020 00:29:54 -0500 Subject: [PATCH] Copy ReceiveSettings.Partitions --- pubsublite/ps/settings.go | 1 + 1 file changed, 1 insertion(+) 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, } }