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
