Re: Producer Async Issue

2017-05-28 Thread Abhimanyu Nagrath
Hey Jay, What will be the disadvantages of setting max.block.ms=0? Regards, Abhimanyu On Mon, May 29, 2017 at 3:15 AM, Jay Kreps wrote: > I think setting max.block.ms=0 does what you want. > > -Jay > > On Sat, May 27, 2017 at 12:40 PM, Abhimanyu Nagrath < > abhimanyunagr...@gmail.com> wrote:

Re: Kafka Streams - possible to know partition?

2017-05-28 Thread Matthias J. Sax
I just added this FAQ: https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-HowcanIaccessrecordmetadata? -Matthias On 5/28/17 12:36 PM, Srimanth G wrote: > Hello, > When using Kafka Streams, is it possible to know which partition the byte[] > are coming from? > > Either in the Serde clas

Re: Producer Async Issue

2017-05-28 Thread Jay Kreps
I think setting max.block.ms=0 does what you want. -Jay On Sat, May 27, 2017 at 12:40 PM, Abhimanyu Nagrath < abhimanyunagr...@gmail.com> wrote: > HI Hans, > > What exactly I meant by asynchronous is that when my Kafka broker is down > and I am trying to produce the message . It is getting stuck

Kafka Streams - possible to know partition?

2017-05-28 Thread Srimanth G
Hello, When using Kafka Streams, is it possible to know which partition the byte[] are coming from? Either in the Serde classes, or any other user accessible functions I would like to know the partition number or any other identifiable information. Thanks SG

Re: [DISCUSS]: KIP-161: streams record processing exception handlers

2017-05-28 Thread Jan Filipiak
+1 On 26.05.2017 18:36, Damian Guy wrote: In that case, though, every access to that key is doomed to failure as the database is corrupted. So i think it should probably die in a steaming heap at that point! On Fri, 26 May 2017 at 17:33 Eno Thereska wrote: Hi Damian, I was thinking of cases

Queries regarding kafka Monitoring tool burrow.

2017-05-28 Thread Abhimanyu Nagrath
Hi , I am using burrow to monitor kafka Lags and I am having following queries : 1.On hitting the API /v2/kafka/local/consumer/group1/lag I am not able to view all the topics details present in that group and getting complete: false in the above JSON. What does this mean? Below mentioned is the j

Re: Kafka Configuration Question

2017-05-28 Thread Sandeep Nemuri
Trace of the error could be helpful to see what is happening. On Thu, May 25, 2017 at 6:50 PM, Raghav wrote: > Looks like you missed attachment of your server.properties file. > > On Wed, May 24, 2017 at 10:25 PM, Bennett, Conrad < > conrad.benn...@verizonwireless.com.invalid> wrote: > > > Hello

Re: KIP-162: Enable topic deletion by default

2017-05-28 Thread Sandeep Nemuri
+1 On Sun, May 28, 2017 at 6:57 AM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > Sure, that sounds good. > > I suggested that to keep command line behavior consistent. > Plus, removal of ACL access is something that can be easily undone, but > topic deletion is not reversible. > So, pe