Hi, Currently the callback of Producer gets either Metadata (partition + offset) or Exception. In case of an exception, it doesn't get any information other than the exception. Which means that if I want to write failures to a "dead letter queue" of some kind, I have to wait on the Future.
I'd like to add RecordBatch to onComplete, so in case of errors we can do something with those records. Questions: 1. Does it seem necessary to anyone else? What do all of you do when the callback receives an exception? 2. Any thoughts on how to add a parameter without causing compatibility issues? I think it will require a new interface (in addition to Callback), but hope there's a better way. Gwen
