how to get spout to re-emit in trident

2015-04-16 Thread
hi, I am new to trident, when we use low level storm api, we call fail(tuple) to tell spout to re-emit tuple what shall we do in trident to get the spout to re-emit? throw a runtime exception? thx

config trident to emit no batch when no data found in kafka

2015-04-08 Thread
hi, i am using trident, and found that when no data found in kafka, spout still emit empty batch can this be turned off? thx!