创建KafkaConsumer 的对象consumer;; 订阅相应的topic 列表;; 调用consumer 的poll 方法拉取订阅的消息。 前面两步在Consumer 底层上只是创建 ...
確定! 回上一頁