Re: ISR not updating

ust be some bad state persisted in ZK. > > > > On 5/17/14 7:50 PM, "Shone Sadler" wrote: > > > > >Hi Jun, > > > > > >I work with Paul and am monitoring the cluster as well. The status has > > >not changed. > > > > > &g

Re: ISR not updating

Hi Jun, I work with Paul and am monitoring the cluster as well. The status has not changed. When we execute kafka-list-topic we are seeing the following (showing one of two partitions having the problem) topic: t1 partition: 33 leader: 1 replicas: 1,2,3 isr: 1 when inspecting the logs of lead

Re: Add Partition and Rebalancing

Just verified the fix. Works great! Thanks for the quick response and fix Guozhang. Shone On Wed, Oct 9, 2013 at 5:32 PM, Shone Sadler wrote: > Ahh yes, thanks Guozhang! > > I thought I did a pull yesterday, but the last change I had was for > Kafka-1073 (below). I did a pull

Re: Add Partition and Rebalancing

epository? It was checked in this Monday, so if you checked out the code > earlier than that then the fix will not be included. > > Guozhang > > > On Wed, Oct 9, 2013 at 1:34 PM, Shone Sadler > wrote: > > > Hello, > > > > > > I am testing out th

Add Partition and Rebalancing

xed, however I am not seeing the expected behavior. Thanks, Shone Sadler

Re: LinkedIn C++ Implementation

Thanks for the heads up Joel. We would like to try if possible (we have ambitious timelines currently). Couple of questions though: - how robust would you consider the failover support in the current version - is there support for compression (Snappy and Gzip)? Thanks in advance! Shone Sadler

LinkedIn C++ Implementation

A few months ago there were discussions around a C/C++ client for Kafka .80 using non-blocking socket I/O that was being worked on by LinkedIn and may possibly be open sourced. Has there been any additional work towards the c++ client and open sourcing it that anyone is aware of? Thanks, Shone

Re: Versioning Schema's

Thanks Jun & Phil! Shone On Thu, Jun 13, 2013 at 12:00 AM, Jun Rao wrote: > Yes, we just have customized encoder that encodes the first 4 bytes of md5 > of the schema, followed by Avro bytes. > > Thanks, > > Jun > > > On Wed, Jun 12, 2013 at 9:50 AM, Shone S

Re: Versioning Schema's

the schema itself. Not > fully sure how this compares with an explicit version field in the schema. > > Thanks, > > Jun > > > On Wed, Jun 12, 2013 at 8:29 AM, Jun Rao wrote: > > > At LinkedIn, we are using option 2. > > > > Thanks, > > > > J

Versioning Schema's

Hello everyone, After doing some searching on the mailing list for best practices on integrating Avro with Kafka there appears to be at least 3 options for integrating the Avro Schema; 1) embedding the entire schema within the message 2) embedding a unique identifier for the schema in the message