Hi, We are using Storm for processing CDC messages from Oracle Golden Gate . Pipeline is as below Oracle GoldenGate-->Queue-->Storm-->Relational DB We have a requirement to hold the messages for a transaction Id till all the messages for that transaction is available in Storm. There can be scenarios like 1 million updates happening in onme transaction source oracle system. Can you please suggest a best approach for holding the messages and then pushing to target db only when all messages for tran id is available in storm.
Regards Pradeep S
