File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -87,10 +87,10 @@ topology.state.synchronization.timeout.secs: 60
87
87
topology.stats.sample.rate : 0.05
88
88
topology.fall.back.on.java.serialization : true
89
89
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
92
92
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
94
94
topology.tick.tuple.freq.secs : null
95
95
topology.worker.shared.thread.pool.size : 4
96
96
topology.disruptor.wait.strategy : " com.lmax.disruptor.BlockingWaitStrategy"
You can’t perform that action at this time.
0 commit comments