Skip to content

Commit 3b099d0

Browse files
fix: Set batching settings on SinglePartitionPublisher (#563)
1 parent 343afbf commit 3b099d0

File tree

1 file changed

+2
-0
lines changed
  • pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam

1 file changed

+2
-0
lines changed

pubsublite-beam-io/src/main/java/com/google/cloud/pubsublite/beam/Publishers.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import com.google.cloud.pubsublite.AdminClientSettings;
2727
import com.google.cloud.pubsublite.MessageMetadata;
2828
import com.google.cloud.pubsublite.Partition;
29+
import com.google.cloud.pubsublite.cloudpubsub.PublisherSettings;
2930
import com.google.cloud.pubsublite.internal.Publisher;
3031
import com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisherSettings;
3132
import com.google.cloud.pubsublite.internal.wire.PubsubContext;
@@ -92,6 +93,7 @@ static Publisher<MessageMetadata> newPublisher(PublisherOptions options) throws
9293
.setTopic(options.topicPath())
9394
.setPartition(partition)
9495
.setServiceClient(newServiceClient(options, partition))
96+
.setBatchingSettings(PublisherSettings.DEFAULT_BATCHING_SETTINGS)
9597
.build())
9698
.setAdminClient(newAdminClient(options))
9799
.build()

0 commit comments

Comments
 (0)