Skip to content

Commit

Permalink
Increase fetch.min.bytes to 64kb for kafka buffer consumer
Browse files Browse the repository at this point in the history
Signed-off-by: Taylor Gray <[email protected]>
  • Loading branch information
graytaylor0 committed Jan 30, 2025
1 parent 414a7c9 commit 2bd3ddb
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ class BufferTopicConfig extends CommonTopicConfig implements TopicProducerConfig
static final boolean DEFAULT_AUTO_COMMIT = false;
static final ByteCount DEFAULT_FETCH_MAX_BYTES = ByteCount.parse("50mb");
static final Duration DEFAULT_FETCH_MAX_WAIT = Duration.ofMillis(1000);
static final ByteCount DEFAULT_FETCH_MIN_BYTES = ByteCount.parse("2kb");
static final ByteCount DEFAULT_FETCH_MIN_BYTES = ByteCount.parse("64kb");
static final ByteCount DEFAULT_MAX_PARTITION_FETCH_BYTES = ByteCount.parse("1mb");
static final Duration DEFAULT_SESSION_TIMEOUT = Duration.ofSeconds(45);
static final String DEFAULT_AUTO_OFFSET_RESET = "earliest";
Expand Down

0 comments on commit 2bd3ddb

Please sign in to comment.