Re: Error "Unknown magic byte" occurred while deserializing Avro message

2016-11-23 Thread Dayong
As I remember this is to complain the fist byte of msg is not x00. I think console producer does not support json since it uses string schema. Thanks, Dayong > On Nov 23, 2016, at 4:28 AM, ZHU Hua B wrote: > > Hi, > > > We tried to produce and consume a AVRO message (zoo

Re: Link read avro from Kafka Connect Issue

2016-11-03 Thread Dayong
Confirmed. It is Magic byte ahead of each avro message. I am able to get it flink consumer work. Thanks you, Dave :) Thanks, Dayong > On Nov 3, 2016, at 8:01 AM, Dayong wrote: > > Not quite sure, will try to find out today. > > Thanks, > Dayong > >> On Nov 2,

Re: Link read avro from Kafka Connect Issue

2016-11-03 Thread Dayong
Not quite sure, will try to find out today. Thanks, Dayong > On Nov 2, 2016, at 9:59 PM, "Tauzell, Dave" > wrote: > > Is Kafka connect adding some bytes to the beginning of the avro with the > scheme registry id? > > Dave > >> On Nov 2, 2016, at 18