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