--TODO
Refactored common code in kafka producer for adding the header and body
potions of the record.
KafkaGenericMutationAvroConsumer now accepts a parameter for it's SchemaId
and is not longer hardcoded to using a Short.