We have a requirement where in we have to read messages from Kafka topic using storm and insert them to database. But we can only do batch insertions... so to achieve this, we are collecting every message(tuple) into a collection and for every 3 seconds we run a thread/timer which persists this collection to a database as a batch update. but we would like to acknowledge only after a collection/batch of messages are persisted to the database, so that failovers can be handled and those failover messages can be re-consumed. Is there any workaround for this issue ... View more