From a79b2a330b055aea93d6f702c2fbff28757aca79 Mon Sep 17 00:00:00 2001
From: dpcollins-google <40498610+dpcollins-google@users.noreply.github.com>
Date: Wed, 3 Mar 2021 09:23:41 -0500
Subject: [PATCH] fix: Add default batching in producer settings (#96)

---
 .../com/google/cloud/pubsublite/kafka/ProducerSettings.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java b/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java
index 073773ad..2a2d525c 100644
--- a/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java
+++ b/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java
@@ -16,6 +16,7 @@
 
 package com.google.cloud.pubsublite.kafka;
 
+import static com.google.cloud.pubsublite.cloudpubsub.PublisherSettings.DEFAULT_BATCHING_SETTINGS;
 import static com.google.cloud.pubsublite.internal.ExtractStatus.toCanonical;
 
 import com.google.api.gax.rpc.ApiException;
@@ -72,6 +73,7 @@ public Producer<byte[], byte[]> instantiate() throws ApiException {
                                         PublisherServiceSettings.newBuilder()))))
                         .setTopic(topicPath())
                         .setPartition(partition)
+                        .setBatchingSettings(DEFAULT_BATCHING_SETTINGS)
                         .build();
                   } catch (Throwable t) {
                     throw toCanonical(t).underlying;