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?
