I'm not aware of any documentation on it. The Disruptor implementation was replaced as of Storm 2.0.0 with JCTools queues. You can find documentation on that here https://issues.apache.org/jira/browse/STORM-2306
If you want to read the code around the Disruptor queue, https://github.com/apache/storm/blob/v1.2.3/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java is a good place to start. Den fre. 6. sep. 2019 kl. 15.41 skrev Nithin Uppalapati (BLOOMBERG/ 731 LEX) <[email protected]>: > Hi, > > Is there some documentation around TOPOLOGY.DISRUPTOR.BATCH.SIZE, I could > not find any good blogs or documentation around it. > > I could understand well about executor and worker process internal buffer > queue's and their role. Would like to understand similarly about disruptor > batch size and timeouts. > > Thanks, Nithin >
