Pass keyDecoder and msgDecoder into connector.createMessageStreams