You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Abhishek Bhattacharjee <ab...@gmail.com> on 2014/01/27 20:03:57 UTC

[Spout using kafka][Need Help]

Hello,
I want to use kafka for my spout.
But I am not inclined towards using the kafka-storm contrib.
Now the problem is I want different consumer threads to fetch data from
different partitions of a topic. This is very simple in kafka.
But how can I write this inside Spout. In storm spouts are threaded
internally and I don't have any control over it. So how can I write my
Spout so that a single thread of spout handles a single partition.

Thanks
*Abhishek Bhattacharjee*
*Pune Institute of Computer Technology*