我在编写producer的时候想自己序列化消息，就按照这段话：
自己编写Encoder来序列化消息，只需实现下面这个接口。默认的Encoder是kafka.serializer.DefaultEncoder。interface Encoder {public Message toMessage(T data);}
重写了toMessage方法，发现出错说让重写toBytes方法，而且源码中的方法确实是toBytes,是因为版本的原因吗？那应该怎么办呢？
http://my.oschina.net/u/1475616/blog/374686