fix: Add default batching in producer settings (#96)

googleapis · Mar 3, 2021 · a79b2a3 · a79b2a3
1 parent a4f012b
commit a79b2a3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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;