public T deserialize(String topic, byte[] data) { return (T) JSON.parse(data); } } 如上簡單的使用fastjson作為序列化和反序列化工具,演示了自定義kafka的序列化和反序列化機(jī)制,我們可以根據(jù)實(shí)際情況來設(shè)計不同的序列化反序列化機(jī)制,當(dāng)然,不會是像上面這些簡單,如果使用spring,那么spring提供了JSON序列化和...
www.dbjr.com.cn/article/2793...htm 2025-5-26