From 00c64446895f0a042238dc37427767b071580fae Mon Sep 17 00:00:00 2001
From: Daniel Collins <dpcollins@google.com>
Date: Mon, 29 Mar 2021 15:49:21 -0400
Subject: [PATCH] fix: Set batching settings on SinglePartitionPublisher

---
 .../main/java/com/google/cloud/pubsublite/beam/Publishers.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/Publishers.java b/pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/Publishers.java
index ad7e2729b..4fb3c7e06 100644
--- a/pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/Publishers.java
+++ b/pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/Publishers.java
@@ -26,6 +26,7 @@
 import com.google.cloud.pubsublite.AdminClientSettings;
 import com.google.cloud.pubsublite.MessageMetadata;
 import com.google.cloud.pubsublite.Partition;
+import com.google.cloud.pubsublite.cloudpubsub.PublisherSettings;
 import com.google.cloud.pubsublite.internal.Publisher;
 import com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisherSettings;
 import com.google.cloud.pubsublite.internal.wire.PubsubContext;
@@ -92,6 +93,7 @@ static Publisher<MessageMetadata> newPublisher(PublisherOptions options) throws
                     .setTopic(options.topicPath())
                     .setPartition(partition)
                     .setServiceClient(newServiceClient(options, partition))
+                    .setBatchingSettings(PublisherSettings.DEFAULT_BATCHING_SETTINGS)
                     .build())
         .setAdminClient(newAdminClient(options))
         .build()