5.1 调用Apache Kafka消息流