I was just looking at STORM-826 <https://github.com/apache/storm/pull/572>and
was wondering if this is the correct approach for doing acks and fails
asynchronously.

> Callback will happen on a different thread. Wouldn't it lead to race
conditions as the disruptor send queues are single producer queues?
> If async is set to false, wouldn't the acks/fails performed twice? Since
callback is always executed by the background thread.

Also if bolt operations are high latency and IO bound, will a non-blocking
implementation without batching lead to increased throughput ?

-- 
Regards,
Abhishek Agarwal

Reply via email to