Skip to content

Commit 2f0cd5c

Browse files
authored
Merge pull request #44 from scalyr/batch-size-increase
Increase default batch send size to 5MB
2 parents 66cf4b7 + b658299 commit 2f0cd5c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

config/connect-scalyr-sink.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ api_key=<log write api key from https://app.scalyr.com/keys>
3030
#add_events_retry_delay_ms=500
3131

3232
# Batch size that must be reached before events are sent. This is to buffer events into larger batches for increased throughput.
33-
#batch_send_size_bytes=4000000
33+
#batch_send_size_bytes=5000000
3434

3535
#Maximum time to wait in millisecs between batch sends. This ensures events are sent to Scalyr in a timely manner on systems under light load where `batch_send_size_bytes` may not be reached for longer periods of time.
3636
#batch_send_wait_ms=5000

src/main/java/com/scalyr/integrations/kafka/ScalyrSinkConnectorConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public class ScalyrSinkConnectorConfig extends AbstractConfig {
3939
public static final String DEFAULT_COMPRESSION_TYPE = "deflate";
4040
public static final int DEFAULT_ADD_EVENTS_TIMEOUT_MS = 20_000;
4141
public static final int DEFAULT_ADD_EVENTS_RETRY_DELAY_MS = 500;
42-
public static final int DEFAULT_BATCH_SEND_SIZE_BYTES = 4_000_000;
42+
public static final int DEFAULT_BATCH_SEND_SIZE_BYTES = 5_000_000;
4343
public static final int DEFAULT_BATCH_SEND_WAIT_MS = 5000;
4444

4545
public static final String SCALYR_SERVER_CONFIG = "scalyr_server";

0 commit comments

Comments
 (0)