That is because the zookeeper read is the slowest thing happening on the producer. I think creating a new producer per thread is a better model.
Thanks, Neha On Tue, Mar 5, 2013 at 1:51 AM, mmLiu <diveintotomor...@gmail.com> wrote: > I notice that if we call *send* method of an async producer in multi-thread > environment, many of these threads will block at > kafka.producer.ZKBrokerPartitionInfo.getBrokerInfo(ZKBrokerPartitionInfo< > https://github.com/apache/kafka/blob/0.7.1/core/src/main/scala/kafka/producer/Producer.scala#L121 > > > .scala:119) > > should I create a new Producer for each msg(or each thread) I send? > > -- > Best Regards > > ---------------------- > 刘明敏 | mmLiu >
