kafka—反序列化

自定义反序列化

public class DefineDeSerializer implements Deserializer<People> { String encode; @Override public void configure(Map<String, ?> configs, boolean isKey) { encode = "UTF-8"; } @SneakyThrows @Override public People deserialize(String topic, byte[] data) { if(data == null) { return null; } People people; people = JSON.parseObject(data, People.class); return people; } @Override public void close() { } }

指定反序列化器

properties.put("value.deserializer", DefineDeSerializer.class.getName())