Re: How does a new broker decide the partitions of the topic?

Thanks yonghui. That makes sense. On Mon, Dec 31, 2012 at 1:45 AM, 永辉 赵 wrote: > Partition name registered in zk contains broker id and sequence(partition) > id, such as "0-0", "0-1", ... > > Thanks, > Yonghui > > > > > > On 12-12-30 下午11:44, "王国栋" wrote: > > >Thanks Yonghui. > > > >But how do

Broker configuration from consumer using API

Hi, I need to get broker configuration information like number of partitions from consumer application using API. I looked at the API and realized I need KafkaBroker instance but I could not find way to get this instance from consumer. Any idea how to get this information? Thanks Subhash A.

Re: java client

We haven't really measured the scala overhead. However, my guess is that it should be small compared to the network overhead, which one has to pay for each request. Thanks, Jun On Fri, Dec 28, 2012 at 7:04 PM, S Ahmed wrote: > Since kafka is written in scala, when using a java client (producer

Re: Broker configuration from consumer using API

We don't have such an api in 0.7. In 0.8, the # of partitions in a topic can be obtained from a getMetadata Api. Thanks, Jun On Mon, Dec 31, 2012 at 10:48 AM, Subhash Agrawal wrote: > Hi, > > I need to get broker configuration information like number of partitions > from consumer application us