From 6da76efea437916c4d05759b61f669600578baa4 Mon Sep 17 00:00:00 2001
From: Daniel Collins <dpcollins@google.com>
Date: Wed, 3 Mar 2021 00:39:22 -0500
Subject: [PATCH] fix: Add default batching in producer settings

---
 .../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;