Yes. Thats right. I misunderstood, my bad. Thanks,
Mayuresh On Thu, Mar 19, 2015 at 11:05 AM, sunil kalva <sambarc...@gmail.com> wrote: > future returns RecordMetadata class which contains only metadata not the > actual message. > But i think *steven* had a point like saving the reference in impl class > and retry if there is an exception in callback method. > > On Thu, Mar 19, 2015 at 10:27 PM, Mayuresh Gharat < > gharatmayures...@gmail.com> wrote: > > > Also you can use the other API that returns a Future and save those > futures > > into a list and do get() on them to check which message has been sent and > > which returned an error so that they can be retried. > > > > Thanks, > > > > Mayuresh > > > > On Thu, Mar 19, 2015 at 9:19 AM, Steven Wu <stevenz...@gmail.com> wrote: > > > > > in your callback impl object, you can save a reference to the actual > > > message. > > > > > > On Wed, Mar 18, 2015 at 10:45 PM, sunil kalva <kalva.ka...@gmail.com> > > > wrote: > > > > > > > Hi > > > > How do i access the actual message which is failed to send to cluster > > > using > > > > Callback interface and onCompletion method. > > > > > > > > Basically if the sender is failed to send, i want to add it to a temp > > > queue > > > > and retry them later. > > > > > > > > --Sunil > > > > > > > > > > > > > > > -- > > -Regards, > > Mayuresh R. Gharat > > (862) 250-7125 > > > > > > -- > SunilKalva > -- -Regards, Mayuresh R. Gharat (862) 250-7125
