卡夫卡8.2.1 - 我應該如何使用KafkaConsumer.poll - 它只是返回null？

Question

卡夫卡新手。

我使用的是卡夫卡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不是kafka 0.8的正確版本？
• 是KafkaConsumer僅在9版本後支持，並且在8版本中不可用？
• 目前卡夫卡最穩定的API是什麼？我以爲是0.8？

Answer 1

支持輪詢的客戶端API僅在最後發佈的版本的Kafka 0.9中可用。對於早期版本，您必須在kafka/core的kafka.consumer包下使用舊的使用者實現。