Hi @Tilak , If I understand your requirement correctly - you want to update the database after a successful publish operation (in the processor). You can try the same logic that I laid out at the start of the discussion.
a) Return a message set with correlation in the processor
b) Before returning, spawn a thread to check on correlation success; if yes, issue your database update
Note that a return from the processor simply hands the control back to the spring cloud stream framework, and you can’t get it back. A CorrelationData class employs a SettableListenableFuture that can be checked on for success/failure later, just instantiate it and set it on the message’s header - you should be able to check on the correlation for the status of the operation.
CorrelationData code is here .