Hi all; I try to publish/consume my java objects to kafka. I use Avro schema.
My basic program works fine. In my program i use my schema in the producer (for encoding) and consumer (decoding). If i publish different objects to different topics( eg: 100 topics)at the receiver, i do not know, what type of message i received. I would like to get the avro schema from the received byte and would like to use that for decoding. Is that right? If so, how can i retrieve from the received object? Or is there any better approach? Thanks. -- -Ratha http://vvratha.blogspot.com/
