What is the best way to publish and consume different type of messages?
<p><strong>Kafka 0.8V</strong></p>

<p>I want to publish /consume byte[] objects, java bean objects, serializable objects and much more..</p>

<p>What is the best way to define a publisher and consumer for this type scenario?
When I consume a message from the consumer iterator, I do not know what type of the message it is.
Can anybody point me a guide on how to design such scenarios?</p>