【发布时间】:2019-09-15 10:06:43
【问题描述】:
我正在使用
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.0.1</version>
</dependency>
以下代码返回非空分配分区,但poll(0)已弃用。
val records = kafkaConsumer.poll(0) // <= deprecated
logInfo(s"Dummy call ${records.count()}")
val partitions = kafkaConsumer.assignment()
logInfo(s"partitions=${partitions}")
以下返回空分区:
val records = kafkaConsumer.poll(Duration.ofMillis(0)) // <= not working
logInfo(s"Dummy call ${records.count()}")
val partitions = kafkaConsumer.assignment()
logInfo(s"partitions=${partitions}")
为什么?有任何想法吗?谢谢
【问题讨论】:
标签: java scala apache-kafka kafka-consumer-api