The magic byte is already in the Kafka Message data format, all you need to
do is upon reading the magic byte for Avro, use your Avro resolver which
treat the first 16 bytes as the schemaId to read the schema.

Guozhang
On Tue, Aug 20, 2013 at 10:54 AM, Mark <[EMAIL PROTECTED]> wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB