Re: Producer creation when brokers are down

2012-04-19 Thread Bo Sun
watch the zookeeper node ,when it exists, zk will callback you code, then try to reconnect the kafka. Thanks On Thu, Apr 19, 2012 at 4:43 PM, Pierre-Yves Ritschard wrote: > Hi, > > Whenever there is a connectivity glitch between producers and brokers > the producers wait for the brokers to be av

Re: Kafka as brokerless/serverless lightweight queue

2012-05-06 Thread Bo Sun
use sbt compile the kafka to a jar. and use it ,make your app as a broker/producer On Sun, May 6, 2012 at 2:34 PM, Erwin Karbasi wrote: > Hello Evan, > > I'd appreciate if you could elaborate how did you embed Kafka in an app? > > Thanks, > Erwin > > On Sat, May 5, 2012 at 6:36 PM, Evan chan wr

Re: kafka.jar in repositories

2012-05-25 Thread Bo Sun
run the command below ./sbt update package and then you will get a kafka.jar On Fri, May 25, 2012 at 1:34 PM, Sam William wrote: > Hi, > Im writing a framework involving kafka consumers in scala and Im using > sbt as the build tool. Where do I get kafka-0.7.jar from ? Is it > available in

Re: about topic rebalance when add the new broker

2012-10-30 Thread Bo Sun
markmail.org/thread/c7tdalfketpusqkg > > Thanks, > > Jun > > On Sun, Oct 28, 2012 at 9:25 PM, Bo Sun wrote: > > > hi all > > > > i have a issue like that > > > > first we have two brokers as the id 0 and 1. and then create the new > > topic .

Re: about topic rebalance when add the new broker

2012-10-30 Thread Bo Sun
ome data to the new broker directly). > > Thanks, > > Jun > > On Tue, Oct 30, 2012 at 1:21 AM, Bo Sun wrote: > > > Thanks Jun. > > but the bug haven't been resolved. If i add the /brokers/topics/test/217 > > zk node (217 is the new broker). it's ok? p