Member since
01-15-2016
2
Posts
1
Kudos Received
0
Solutions
01-21-2016
11:23 PM
Thanks a lot for your reply Artem Ervits. I have one more question. What happens a transaction fails while persisting to the database. we have code within a bolt to persist to database and if database is down for any reason, can we replay the tuple to persist the tuple/message to database
... View more
01-15-2016
04:50 PM
1 Kudo
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
Labels: