Hello Folks, Requesting your expertise on this. I see that under core/src/main/scala/kafka/producer/, there are many implementations - Producer.scala and SyncProducer.scala
Also, going via the producerPerformance.scala, there are 2 implementations - NewShinyProducer (which points to KafkaProducer.java) and the OldProducer Similar might be the case with Consumers, but I have not seen that yet. Please let me know which producer and consumer is supposed to be used and which ones will be phased out in future releases, so I can focus on only 1 type of producer and consumer (high level as well as simple) Thanks, Prabhjot Thanks, Prabhjot On Thu, Nov 5, 2015 at 3:55 PM, Prabhjot Bharaj <prabhbha...@gmail.com> wrote: > Adding users as well > > On Thu, Nov 5, 2015 at 3:37 PM, Prabhjot Bharaj <prabhbha...@gmail.com> > wrote: > >> Hi, >> >> I'm using the latest update: 0.8.2.2 >> I would like to use the latest producer and consumer apis >> over the past few weeks, I have tried to do some performance benchmarking >> using the producer and consumer scripts provided in the bin directory. It >> was a fun activity and I have learnt a lot about kafka. >> >> But, I have also experienced that sometimes the implementation of the >> performance scripts was not up-to-date or some items were different than >> the documentation >> >> Now, I would like to develop my application with kafka. I'm comfortable >> using scala/java >> >> Please let me know which producer and consumer (both high level and >> simple) class/object should I be using >> >> Thanks a lot, >> Prabhjot >> > > > > -- > --------------------------------------------------------- > "There are only 10 types of people in the world: Those who understand > binary, and those who don't" > -- --------------------------------------------------------- "There are only 10 types of people in the world: Those who understand binary, and those who don't"
