I'm assuming you mean DirectRunner and not DataflowDirectRunner. On Wed, Jan 11, 2017 at 4:23 PM, Raghu Angadi <[email protected]> wrote:
> > On Wed, Jan 11, 2017 at 1:56 PM, Madhire, Naveen < > [email protected]> wrote: > >> I can confirm the authorization and authentication to Kafka is behaving >> correctly, >> > > Did you confirm this within Beam/KafkIO context or outside? When I last > checked Kafka requires the the credentials file to be available on local > filesystem where the KafkaConsumer runs. All the workers need to have this > file. Shipping these files to workers depends on the runner/execution > environment. > > Can you try with DataflowDirectRunner? That would be simpler to debug. > > Raghu. > >
