代码之家 › 专栏 › 技术社区 › vatsal mevada

Kafka客户机版本0.8.2时,Kafka Consumer Poll始终返回空值

kafka-consumer-api apache-kafka

1

vatsal mevada · 技术社区 · 7 年前

我已经用 kafka-clients-0.8.2.0 应用程序编程接口。

令人惊讶的呼叫 KafkaConsumer#poll 方法始终返回 null . 我检查了KafkaConsumer的源代码,结果发现 poll 方法被硬编码以返回 无效的 总是这样。

@Override
public Map<String, ConsumerRecords<K,V>> poll(long timeout) {
        // TODO Auto-generated method stub
        return null;
}

我很好奇为什么要这样保存。我是不是错过了什么?

1 回复 | 直到 7 年前

1

0

Maksim Kostromin 7 年前

not yet implemented