关于kafka的Encoder问题

Question

我在编写producer的时候想自己序列化消息，就按照这段话：

自己编写Encoder来序列化消息，只需实现下面这个接口。默认的Encoder是kafka.serializer.DefaultEncoder。
interface Encoder {

public Message toMessage(T data);

}

重写了toMessage方法，发现出错说让重写toBytes方法，而且源码中的方法确实是toBytes,是因为版本的原因吗？那应该怎么办呢？

Answer 1

http://my.oschina.net/u/1475616/blog/374686