Thanks a lot On 13 Apr 2015 06:08, "Manoj Khangaonkar" <[email protected]> wrote:
> Clarification. My answer applies to the new producer API in 0.8.2. > > regards > > On Sun, Apr 12, 2015 at 4:00 PM, Manoj Khangaonkar <[email protected]> > wrote: > > > Hi, > > > > For (1) from the java docs "The producer is *thread safe* and should > > generally be shared among all threads for best performance" > > > > (2) (1) implies no pool is necessary. > > > > regards > > > > On Sun, Apr 12, 2015 at 12:38 AM, dhiraj prajapati <[email protected] > > > > wrote: > > > >> Hi, > >> I want to send data to apache kafka using the java api of the kafka > >> producer. The data will be in high volume, of the order of more than 5 > >> thousand messages per second. > >> Please help me with the following queries: > >> > >> 1. Should I create only one producer object for the entire app and use > the > >> same object to send all the messages and then close the producer in the > >> end? Or should I create a producer object for every message to be sent > and > >> close the producer connection after sending each message? > >> > >> 2. Does the producer api inherently use a pool of Producer objects? If > >> yes, > >> what is the default size of the pool and is it configurable? > >> > >> Thanks in advance, > >> Dhiraj Prajapati > >> > > > > > > > > -- > > http://khangaonkar.blogspot.com/ > > > > > > -- > http://khangaonkar.blogspot.com/ >
