Yes, there is a version of createDirectStream that lets you specify fromOffsets: Map[TopicAndPartition, Long]
On Mon, Nov 30, 2015 at 7:43 PM, Alan Braithwaite <a...@cloudflare.com> wrote: > Is there any mechanism in the kafka streaming source to specify the exact > partition id that we want a streaming job to consume from? > > If not, is there a workaround besides writing our a custom receiver? > > Thanks, > - Alan >
