5.3.2 Quarkus调用Kafka消息流