There is some logging at INFO level. e.g. you should see log at line 692 <https://github.com/apache/incubator-beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L692> in the client side (where you launch the app from).. and line 932 or 935 <https://github.com/apache/incubator-beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L935> on the workers. Which runner are you using?
On Wed, Jun 8, 2016 at 12:55 PM, Jesse Anderson <[email protected]> wrote: > 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? >> >
