Remoting Kafka Plugin implements its own Command Transport, which creates Command Instances. Proper deserialization of Commands requires setting proper classloader and a local channel instances.
There is a Command#readFrom() method which does it, but it's package-private. Also, a construction of the ObjectInputStreamEx requires package-private Channel fields.
I propose to create a public Channel#readFrom(Channel, byte payload) method so that it can be used externally