sclasen/akka-kafka — pull request #1 by kelvl (2014-05-16 00:52:30+00:00)
Title: Pass keyDecoder and msgDecoder into connector.createMessageStreams

KeyDecoder and MsgDecoder from props was not passed into createMessageStreams, resulting in messages to only be decoded as Array[Byte]