Hi Chinmay,

Zitat von Chinmay Soman <[email protected]>:
[....]
Also, I'm guessing if I have to add some custom tuning mechanism for this,
its going to be part of the Storm core ? Or is there a pluggable way to add
a custom logic to manage max.spout.pending ?

you can always run your own code inside your spout, tracking the number of emitted vs. the number of ack/failed tuples...

Regards,
Jens



Reply via email to