关于kafka的Encoder问题

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

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

public Message toMessage(T data);

}

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

查看全部
Ycoronene
Ycoronene
2015/08/19 14:03
  • tomessage
  • kafka
  • serializer
  • tobytes
  • encoder
  • 点赞
  • 收藏
  • 回答
    私信

1个回复