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

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:

Any ideas ?

Thanks you !

1 Like