* Consumer now returns instances of internal `Message` class, that wrap confluent-kafka Message, with lazy deserialization * Basic metrics via dd-statsd * Improved callbacks
0.10.0
* proper error handling in consumer, * producer callbacks
0.9.0
* skip decoding of "tombstone" message values * AvroRecord base class for creating producer messages