5.2 通过Kafka队列扩展