Fixing bug in decoding message streams

The Kafka integration in master uses the value decoder to decode both keys & values--this causes problems if your keys & values are of different types. :v: