Re: [DISCUSS] Kafka Security Specific Features

Raja, Which Kafka version is your security enhancement based on? thanks, Cal On Wed, Jul 23, 2014 at 5:01 PM, Chris Neal wrote: > Pramod, > > I got that same error when following the configuration from Raja's > presentation earlier in this thread. If you'll notice the usage for the > conso

Issue with unit testing Kafka on 0.8.1.1 and scala 2.9.2

Hi, i have been trying to run the kafka server using TestUtils.for my unit tests, while the topic gets created, i'm getting the following error error when handling request Name:LeaderAndIsrRequest;Version:0;Controller:0;ControllerEpoch:1;CorrelationId:9;ClientId:id_0-host_localhost-port_9000;Le

Re: Lost messages during leader election

Great! Thanks! On Tue, Jul 29, 2014 at 10:57 AM, Guozhang Wang wrote: > Good to know. The issue with initial replica factor = 1 is still a real bug > though, and I will probably fix it along with KAFKA-1430. > > Guozhang > > > On Tue, Jul 29, 2014 at 10:27 AM, Jad Naous > wrote: > > > OK, it l

Re: Lost messages during leader election

Good to know. The issue with initial replica factor = 1 is still a real bug though, and I will probably fix it along with KAFKA-1430. Guozhang On Tue, Jul 29, 2014 at 10:27 AM, Jad Naous wrote: > OK, it looks like if the initial replica count was 2 for the topic, then > this doesn't happen. Go

Re: Lost messages during leader election

OK, it looks like if the initial replica count was 2 for the topic, then this doesn't happen. Good catch Guozhang, and sorry for the oversight! On Mon, Jul 28, 2014 at 5:29 PM, Guozhang Wang wrote: > Yeah, please try that and let us know. > -- *Jad Naous* | Engineering | AppDynamics

Re: request.required.acks in Async Mode

request.required.acks and producer.mode (sync or async) are orthogonal configs, i.e. with async mode, the producer.send() call itself will not be blocking on acks from the servers, but its async sending thread will still be blocked for acks, and if it fails to send out the messages due to, say, tim