> > properties.put("value.serializer",StringSerializer.
> > > class.getCanonicalName());
> > >
> > > properties.put("acks", "-1");
> > >
> > > properties.put("retries&
uot;, 1);
> >
> > return new KafkaProducer<>(properties);
> >
> > }
> >
> >
> >
> > private BufferedReader getBufferedReader(String filePath, String
> encoding)
> > throws UnsupportedEncodingException, FileNotFoundExcepti
gt; -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 for a single record file wi
t;
>
> private BufferedReader getBufferedReader(String filePath, String encoding)
> throws UnsupportedEncodingException, FileNotFoundException {
>
> return new BufferedReader(new InputStreamReader(new
> FileInputStream(filePath), Optional.ofNullable(encoding).
> orElse("UTF-8
return new BufferedReader(new InputStreamReader(new
FileInputStream(filePath), Optional.ofNullable(encoding).orElse("UTF-8")));
}
Regards,
Vatsal
-Original Message-
From: Rajini Sivaram [mailto:rajinisiva...@googlemail.com]
Sent: 06 December 2016 17:27
T
ng 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
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 c
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
Or am I
missing something in my code?
My Kafka version is 0.10.0.1.
Regards,
Vatsal
Am I missing any configuration or
-Original Message-
From: Ismael Juma [mailto:isma...@gmail.com]
Sent: 02 December 2016 13:30
To: Kafka Users
Subject: RE: Detecting when all the retries are expired for a
So I think I should not face
> the issue that you are mentioning. I mentioned documentation link of 0.9 by
> mistake.
>
> Regards,
> Vatsal
> -Original Message-
> From: Asaf Mesika [mailto:asaf.mes...@gmail.com]
> Sent: 02 December 2016 00:32
> To: Kafka Users
&g
016 00:32
To: Kafka Users
Subject: Re: Detecting when all the retries are expired for a message
There's a critical bug in that section that has only been fixed in 0.9.0.2
which has not been release yet. Without the fix it doesn't really retry.
I forked the kafka repo, applied the fix
There's a critical bug in that section that has only been fixed in 0.9.0.2
which has not been release yet. Without the fix it doesn't really retry.
I forked the kafka repo, applied the fix, built it and placed it in our own
Nexus Maven repository until 0.9.0.2 will be released.
https://github.com/
The callback should give you what you are asking for. Has it not 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:
>
>
>
> public void produce(Strin
13 matches
Mail list logo
