kafka消息持久化处理