返回到文章

采纳

编辑于

kafka V2.1.1 poll 方法过时

kafka

最近把kafka版本升到了2.1.1 版本,发现poll方法过时了,请问2.1.1版本拉取消息应该用哪个api?

kafka client pom

 <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.1.1</version>
</dependency>

项目中的用到的poll方法

 ConsumerRecords<K, V> records = kafkaConsumer.poll(10 * 1000);