Hi, avro Schemas imply a pretty big overhead, if you would include them in every message. It's good practice to include a schema id with the message... Then you need a schema repository to lookup the matching schema based on the id.
Have a look at confluent.io. They offer a schema repo among other Kafka related tools. Regards Jan Sent from my iPhone > On 19 Apr 2016, at 08:02, Ratha v <vijayara...@gmail.com> wrote: > > 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/
