I started to put thoughts on what a schema based topic would look like https://cwiki.apache.org/confluence/display/KAFKA/Schema+based+topics
The main idea around this feature is that topics will have a registry of what schemas it support and validate for producing and return (in addition to the key, message) a schemaHash. /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/
