本文主要是介绍解析kafka topic中的数据，序列化成传输对象，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
/*** ** @param consumerRecordList kafka消息内容* @return 传输对象列表*/
private List<NewsEventDTO> parse(List<ConsumerRecord<String, String>> consumerRecordList) {return consumerRecordList.stream().map(record -> JSONObject.parseObject(record.value(), NewsEventDTO.class)).filter(Objects::nonNull).collect(Collectors.toList());
}
这篇关于解析kafka topic中的数据，序列化成传输对象的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
