Merge pull request #275 from GoogleCloudPlatform/smaller_buffer_no_ov…

…ersize Make the maximum buffer size 9.5 MB instead of 10 MB to prevent errors.
GoogleCloudPlatform · Apr 30, 2021 · e2ab33b · e2ab33b
2 parents d15d147 + 2f4b044
commit e2ab33b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java b/kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java
@@ -46,7 +46,7 @@ public class CloudPubSubSinkConnector extends SinkConnector {
   public static final String MAX_TOTAL_TIMEOUT_MS = "maxTotalTimeoutMs";
   public static final String MAX_SHUTDOWN_TIMEOUT_MS = "maxShutdownTimeoutMs";
   public static final int DEFAULT_MAX_BUFFER_SIZE = 100;
-  public static final long DEFAULT_MAX_BUFFER_BYTES = 10000000L;
+  public static final long DEFAULT_MAX_BUFFER_BYTES = 9500000L;
   public static final int DEFAULT_DELAY_THRESHOLD_MS = 100;
   public static final int DEFAULT_REQUEST_TIMEOUT_MS = 10000;
   public static final int DEFAULT_TOTAL_TIMEOUT_MS = 60000;