利用Kafka实现IM系统的写扩散模型