java Kafka 8.2.1如何使用KafkaConsumer。轮询它只返回null？

Question

卡夫卡新手

我正在使用kafka 0.8.2.1 java库：

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

我试图使用consumer.poll，但它立即返回。当我查看源代码时，我看到它只返回null

• 我看错东西了吗？0.8.2.1不是卡夫卡0.8的正确版本吗
• 只有在9版本之后才支持KafkaConsumer，而在8版本中不支持吗
• 卡夫卡目前最稳定的API是什么？我以为是0.8

Answer 1

支持民意调查的消费者API仅在Kafka 0.9中提供，后者是最新发布的版本。对于早期版本，您必须使用卡夫卡下较旧的消费者实现。kafka/core的消费者套餐