Say the kafka spout fetched some messages and at that time the spout task is restarted. Will the fetched messages be lost? I'm a starter on trident and my question is for the trident kafka transactional/opaque spout.
Thanks in advance!
I believe as long as the messages are not ack they wont be commited as consumed and the spout will replay them when started .
On the other hand if you configure your spout to read from the beginning then Kafka-sppout will fetch them from the starting offset point.