回复：How Kafka work internally?

[黄刚 <ga...@dmall.com>]

you don’t need the full broker list for “metadata.broker.list”, one healthy broker will get metadata from zk, and then return to the produce client.


原始邮件
发件人:Kiran Singhkim.singh15@gmail.com
收件人:usersusers@kafka.apache.org
发送时间:2015年10月19日(周一) 19:43
主题:How Kafka work internally?


Hi I am using producer API to send data to a topic. For this I am using "metadata.broker.list" to specify my broker list and i am able to send data successfully. But i am looking for how Kafka server handle a producer API means 1. which broker act as a coordinator for the send request. As we know only partition leader has the permission to write message into a partition. But if i have topic with partition 3 and in my "metadata.broker.list" i am pass only one broker details, even then i am able to send my message. 2. Every send request will hit one broker in the list or Kafka use some kind of load balancing to handle send request. Thanks Kiran Singh

Re: How Kafka work internally?

[Kiran Singh <ki...@gmail.com>]

What mean by healthy broker?

On Mon, Oct 19, 2015 at 5:26 PM, 黄刚 <ga...@dmall.com> wrote:

> you don’t need the full broker list for “metadata.broker.list”, one
> healthy broker will get metadata from zk, and then return to the produce
> client.
>
>
> 原始邮件
> 发件人:Kiran Singhkim.singh15@gmail.com
> 收件人:usersusers@kafka.apache.org
> 发送时间:2015年10月19日(周一) 19:43
> 主题:How Kafka work internally?
>
>
> Hi I am using producer API to send data to a topic. For this I am using
> "metadata.broker.list" to specify my broker list and i am able to send data
> successfully. But i am looking for how Kafka server handle a producer API
> means 1. which broker act as a coordinator for the send request. As we know
> only partition leader has the permission to write message into a partition.
> But if i have topic with partition 3 and in my "metadata.broker.list" i am
> pass only one broker details, even then i am able to send my message. 2.
> Every send request will hit one broker in the list or Kafka use some kind
> of load balancing to handle send request. Thanks Kiran Singh
>