Skip to content

Commit 0d07a46

Browse files
Increase the default buffer configurations by 25. Capacity to 12,800 and batch size to 200. (#1906) (#1907)
Signed-off-by: David Venable <[email protected]> (cherry picked from commit 29a4a97) Co-authored-by: David Venable <[email protected]>
1 parent 5c706de commit 0d07a46

File tree

1 file changed

+2
-2
lines changed
  • data-prepper-plugins/blocking-buffer/src/main/java/org/opensearch/dataprepper/plugins/buffer/blockingbuffer

1 file changed

+2
-2
lines changed

data-prepper-plugins/blocking-buffer/src/main/java/org/opensearch/dataprepper/plugins/buffer/blockingbuffer/BlockingBuffer.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,8 @@
4343
@DataPrepperPlugin(name = "bounded_blocking", pluginType = Buffer.class)
4444
public class BlockingBuffer<T extends Record<?>> extends AbstractBuffer<T> {
4545
private static final Logger LOG = LoggerFactory.getLogger(BlockingBuffer.class);
46-
private static final int DEFAULT_BUFFER_CAPACITY = 512;
47-
private static final int DEFAULT_BATCH_SIZE = 8;
46+
private static final int DEFAULT_BUFFER_CAPACITY = 12_800;
47+
private static final int DEFAULT_BATCH_SIZE = 200;
4848
private static final String PLUGIN_NAME = "bounded_blocking";
4949
private static final String ATTRIBUTE_BUFFER_CAPACITY = "buffer_size";
5050
private static final String ATTRIBUTE_BATCH_SIZE = "batch_size";

0 commit comments

Comments
 (0)