Hi Ratha,

Do you want to give a try to the schema registry and Avro serializers using
it?
http://docs.confluent.io/2.0.1/schema-registry/docs/serializer-formatter.html#serializer

Thanks,
Liquan

On Mon, Apr 18, 2016 at 11:02 PM, 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/
>



-- 
Liquan Pei
Software Engineer, Confluent Inc

Reply via email to