Let me update my code guys, here is the new version: https://pastebin.com/UdT4D7VW
On Wed, May 1, 2019 at 11:10 AM Juan Carlos Garcia <jcgarc...@gmail.com> wrote: > Hi Andres, > > You are missing the call to pipeline method *run()* > > JC > > On Wed, May 1, 2019 at 4:35 PM Andres Angel < > ingenieroandresan...@gmail.com> wrote: > >> Hello everyone, >> >> Guys I'm trying to consume a kafka topic within my job pipeline, the main >> idea is firs read the payload from the kafka topic using KafkaIO, this read >> will return a PCollection<KafkaRecord<Long,String>> then I want to turn >> this into a PCollection<KV<String,String>> where later I might be able to >> read the V and turn it into a PCollection<String>. >> >> I have designed a first sample code : https://pastebin.com/UdT4D7VW and >> at the line 18 I added a print hoping visualize the value payload in order >> to create later my final PCollection<String>, however when I run the >> pipeline it doesnt print anything so I dont know if is really even >> consuming my topic. >> >> Question: >> * How should I debug this to know where I'm? I'm using IntelliJ , Java 8 >> and maven 3 >> * Am I right on my assumptions to read >> the PCollection<KafkaRecord<Long,String>> into PCollection<String> ? >> * There is any other better way? >> >> thanks so much >> AU >> > > > -- > > JC > >
