Hi, I build a topo to get messages from by kafka, and then grep some keyword, if fit, write to local file.
I use OpaqueTridentKafkaSpout of storm-kafka to ensure the tuple will not miss or repeate, but consider one situation: when writing message to local file, and some error occurse(for example, not enough space). At this moment, some messages have writen to local file, and others not, if the spout resend the message, the message will be write twice. how to do that?thanks. jinhong_lu
