最近把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);