对于Kafka客户端版本0.8.2kafkaconsumer#poll总是返回null

Question

我使用Kafka-Clients-0.8.2.0API编写了一个最小的Kafka消费者代码。

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

我很好奇它为什么会那样保存。我是不是漏掉了什么？

Answer 1

似乎这是Kafka-客户机库中的一个bug。版本0.8.1甚至没有消费者包，所以对我来说，它只是在0.8.2发布时还没有实现。当然，通过使用eclipse自动生成的方法返回null，这是非常糟糕的做法。相反，应该有某种异常尚未实现消息或类似的东西，但它是什么...

使用Kafka-Clients0.9.0，该版本包含轮询方法实现。