Re: Network failure leads to split brain in brokers

Hi Guozhang, I am using 0.8.0 release Regards, Abhinav On Thu, Jun 19, 2014 at 2:06 AM, Guozhang Wang wrote: > Hello Abhinav, > > Which Kafka version are you using? > > Guozhang > > > On Wed, Jun 18, 2014 at 1:40 AM, Abhinav Anand wrote: > > > Hi Guys, >

Network failure leads to split brain in brokers

ent id cse-sauron for 0 topic(s) [] 2014-06-17 01:01:54 INFO: com.linkedin.camus.etl.kafka.CamusJob - cse-sauron uri:tcp://dare-broker02.sv.walmartlabs.com:9092 leader:3 partition:0 offset:10253311 latest_offset:10697656 Let me know if you need any more details -- Abhinav Anand

Re: Impact of slow consumers

pic1, with one of them slow, or do you mean all > consumers are slow in that group, or do you use a simple consumer? When you > say "throughput", do you mean consumer side throughput, or broker side > throughput? > > Guozhang > > > On Tue, Mar 18, 2014 at 4:25 PM, Abhi

Impact of slow consumers

ow do handle such rogue consumers as a part of operation ? -- Abhinav Anand

Producer load balancing

configuration to enable round robin message delivery ? -- Abhinav Anand

Re: Java major.minor version error

ingshadoop> > ****/ > > > On Thu, Jan 23, 2014 at 2:21 AM, Abhinav Anand wrote: > > > Hi Joe, > > I am trying to setup a Kafka Simple Consumer in java. I am using the > > kafka.consumer.Consumer.creat

Re: Java major.minor version error

1:22 PM, Joe Stein wrote: > > > Can you share your reference? > > > > > > /*** > > Joe Stein > > Founder, Principal Consultant > > Big Data Open Source Security LLC > > http://www.stealth.ly > > Twitter: @allthingshadoop > >

Re: Java major.minor version error

/ > > > On Wed, Jan 22, 2014 at 5:16 PM, Abhinav Anand wrote: > > > I am using jre 1.6. > > > > All the release candidates were built against 1.7. was the final release > > also built against 1.7 ? > > > > > > On Thu, Jan 23, 2014

Re: Java major.minor version error

I am using jre 1.6. All the release candidates were built against 1.7. was the final release also built against 1.7 ? On Thu, Jan 23, 2014 at 3:25 AM, Abhinav Anand wrote: > Hi, > I have kafka_2.10 version 0.8.0 in my maven dependency. I am trying to > run a consumer. It is

Java major.minor version error

? -- Abhinav Anand

Re: Producer reaches a max of 7Mbps

plan to address the 08 throughput issue in 09. > > Thanks, > Neha > On Nov 18, 2013 11:50 PM, "Abhinav Anand" wrote: > > > Hi, > > I am using kafka producer and broker for a production setup. The > expected > > producer output is 20MBps but I am only getting

Producer reaches a max of 7Mbps

log.flush.interval.messages=1000 log.flush.interval.ms=300 log.retention.hours=48 log.retention.bytes=107374182400 log.segment.bytes=536870912 log.cleanup.interval.mins=1 zookeeper.connect=dare-msgq00:2181,dare-msgq01:2181,dare-msgq02:2181 zookeeper.connection.timeout.ms=100 -- Abhinav Anand

Plan for Scala 2.10+ support

application. We are currently maintaining our own repository of Kafka build over scala_2.10. Though we wanted to open-source our system and wanted to check if there is any plan for Kafka_2.10 getting pushed to maven or apache repository ?? -- Abhinav Anand