Skip to content

Commit 1ff1af8

Browse files
author
Nathan Marz
committed
change default buffer sizes to work better in local mode and have less latency spikes
1 parent ae41243 commit 1ff1af8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

conf/defaults.yaml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,10 +87,10 @@ topology.state.synchronization.timeout.secs: 60
8787
topology.stats.sample.rate: 0.05
8888
topology.fall.back.on.java.serialization: true
8989
topology.worker.childopts: null
90-
topology.executor.receive.buffer.size: 8192 #batched
91-
topology.executor.send.buffer.size: 16384 #individual messages
90+
topology.executor.receive.buffer.size: 1024 #batched
91+
topology.executor.send.buffer.size: 1024 #individual messages
9292
topology.receiver.buffer.size: 8 # setting it too high causes a lot of problems (heartbeat thread gets starved, throughput plummets)
93-
topology.transfer.buffer.size: 32 # batched
93+
topology.transfer.buffer.size: 1024 # batched
9494
topology.tick.tuple.freq.secs: null
9595
topology.worker.shared.thread.pool.size: 4
9696
topology.disruptor.wait.strategy: "com.lmax.disruptor.BlockingWaitStrategy"

0 commit comments

Comments
 (0)