Hi,
I am reading a file and dumping each record on Kafka. Here is my producer code:
public void produce(String topicName, String filePath, String bootstrapServers,
String encoding) {
try (BufferedReader bf = getBufferedReader(filePath, encoding);
t; worked as you expect when you tried it?
>
> Ismael
>
> On Thu, Dec 1, 2016 at 1:22 PM, Mevada, Vatsal
>
> wrote:
>
> > Hi,
> >
> >
> >
> > I am reading a file and dumping each record on Kafka. Here is my
> > producer
> > code:
>
message
The callback is called after the retries have been exhausted.
Ismael
On 2 Dec 2016 3:34 am, "Mevada, Vatsal" wrote:
> @Ismael:
>
> I can handle TimeoutException in the callback. However as per the
> documentation of Callback(link: https://kafka.apache.or
Hello,
Bumping up this thread in case anyone of you have any say on this issue.
Regards,
Vatsal
-Original Message-
From: Mevada, Vatsal
Sent: 02 December 2016 16:16
To: Kafka Users
Subject: RE: Detecting when all the retries are expired for a message
I executed the same producer code
ure out the behavior without looking into the
code.
On Tue, Dec 6, 2016 at 10:10 AM, Asaf Mesika
mailto:asaf.mes...@gmail.com>> wrote:
> Vatsal:
>
> I don't think they merged the fix for this bug (retries doesn't work)
> in 0.9.x to 0.10.0.1: https://github
