如何将Kafka消费多个server的Java代码改写成长尾?