Skip to content

Commit 2bd3ddb

Browse files
committed
Increase fetch.min.bytes to 64kb for kafka buffer consumer
Signed-off-by: Taylor Gray <tylgry@amazon.com>
1 parent 414a7c9 commit 2bd3ddb

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/buffer

data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/buffer/BufferTopicConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ class BufferTopicConfig extends CommonTopicConfig implements TopicProducerConfig
2727
static final boolean DEFAULT_AUTO_COMMIT = false;
2828
static final ByteCount DEFAULT_FETCH_MAX_BYTES = ByteCount.parse("50mb");
2929
static final Duration DEFAULT_FETCH_MAX_WAIT = Duration.ofMillis(1000);
30-
static final ByteCount DEFAULT_FETCH_MIN_BYTES = ByteCount.parse("2kb");
30+
static final ByteCount DEFAULT_FETCH_MIN_BYTES = ByteCount.parse("64kb");
3131
static final ByteCount DEFAULT_MAX_PARTITION_FETCH_BYTES = ByteCount.parse("1mb");
3232
static final Duration DEFAULT_SESSION_TIMEOUT = Duration.ofSeconds(45);
3333
static final String DEFAULT_AUTO_OFFSET_RESET = "earliest";

0 commit comments

Comments
 (0)