Hi, I want to understand how and where the disruptor queue is used.
From: [email protected] At: 09/06/19 10:47:39To: [email protected] Subject: Re: Topology Disruptor Batch Size 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
