Hi Shekar, Please have a look at [1].
Milinda [1] https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example On Mon, Jun 29, 2015 at 1:06 PM, Shekar Tippur <ctip...@gmail.com> wrote: > Benjamin, > > Thanks for the explanation. We dont have any specific partition scheme as > yet. We just have 2 topics - raw and processed and we use default > partitioning scheme. > Can you share any code snippet so I can understand it better? > > - Shekar > -- Milinda Pathirage PhD Student | Research Assistant School of Informatics and Computing | Data to Insight Center Indiana University twitter: milindalakmal skype: milinda.pathirage blog: http://milinda.pathirage.org
