Get a business context when handling an exception occurring at Kafka Producer stage

[amaumont (Axel Maumont)]

I’m looking for a solution to get the source object (or at least a business identifier) which lead to a Kafka error occurring at the Producer stage.
I expect to send a message to a specific actor according to the business object where occurred the exception.
For example, it would be interesting that the passThrough object could be provided in the exception, this would be the perfect solution for my need.

I already read the following post yet like the error occurs at Kafka stage I cannot customize the exception with the desired business identifier:

Retry stream in akka on failure of any stage in flow

I am using akka stream to process my data. In which i have 1 Source which consist of element UUID. The flow is as follows : is fetching the Element from some third party HTTP service which return complete Element with its properties. Then i retrieve required data from that element and convert it to object that my application understands. Then i write the data from that object to DB. Finally i update the DB with status of all the elements in the stream. Now i want to add retry mecha…

Any ideas ?

Thanks you !