Most of the KafkaIO tests on DirectRunner are using withMaxNumRecords which creates a BoundedReadFromUnboundedSource
Regards Sumit Chawla On Fri, Sep 2, 2016 at 11:07 AM, Raghu Angadi <rang...@google.com.invalid> wrote: > On Tue, Aug 30, 2016 at 12:01 AM, Chawla,Sumit <sumitkcha...@gmail.com> > wrote: > > > Sorry i tried with DirectRunner but ran into some kafka issues. > Following > > is the snippet i am working on, and will post more details once i get it > > working ( as of now i am unable to read messages from Kafka using > > DirectRunner) > > > > would like to know more about issues you are running into. KafkaIO should > work with DirectRunner, that is how it often tested (unit tests also run on > DirectRunner). >
