Thanks for the insight Jay. On Wed, Jan 4, 2012 at 11:30 AM, Jay Kreps <jay.kr...@gmail.com> wrote:
> The producer is thread safe. > > Whether or not you will see throughput advantages from having multiple > producer instances depends on your usage, you will have to try it out. For > larger messages or using the producer in async mode, one producer can > pretty easily saturate the network and adding more producers won't add much > in the way of throughput. For small messages sent in sync mode having more > than one may improve throughput. > > -Jay > > 2012/1/4 Patricio Echagüe <patric...@gmail.com> > > > Hi all, I'm trying to get familiar with Kafka code base and scala. I > > haven't been to answer the question myself yet. > > > > I have a bunch of threads (managed by a Thread pool executor in Java) and > > would like to know/ask recommendation as far as thread-safety goes on the > > producer side. > > > > Should I have one producer object per thread ? or one for all ? > > > > I read in an old email that the producer has proper synchronization, but > > It's not clear if it follows the concurrent approach similar to > > java.concurrent package style or if it's simple java synchronization. My > > goal is to not slow down the message generation. > > > > Thanks in advance. > > Patricio > > >
