Re: Need a working example to read/write avro data using FlinkKafkaProducer / Consumer

2016-04-27 Thread Maximilian Michels
Hi Kaniska, I've replied to your mail on the Beam user mailing list. Cheers, Max On Wed, Apr 27, 2016 at 4:56 PM, kaniska Mandal wrote: > I am facing some issues while reading / writing Avro data. > > Attached here the corresponding files and avro-generated pojo. > > Any clues whats wrong here

Need a working example to read/write avro data using FlinkKafkaProducer / Consumer

2016-04-27 Thread kaniska Mandal
I am facing some issues while reading / writing Avro data. Attached here the corresponding files and avro-generated pojo. Any clues whats wrong here ? May be missing some simple step ! *A) << producer >> BeamKafkaFlinkAvroProducerTest * >> if I use KafkaProducer directly (i.e. call produceSi