Nothing gets logged out. Do I need to change a log level? On Wed, Jun 8, 2016, 3:54 PM Raghu Angadi <[email protected]> wrote:
> On Wed, Jun 8, 2016 at 12:35 PM, Jesse Anderson <[email protected]> > wrote: > >> In my code, I create a KafkaIO.read() that is processed by a >> MapElements.via(). The lamdba in the via is never called. I've verified >> there is data in the topic and I've manually added data using the console >> producer. Still, no data. > > > Do you have logs from KafkaIO? >
