Kafka新手。
我正在使用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不是Kafka0.8的正确版本吗？
是 KafkaConsumer 仅在9版本后支持，在8版本中不可用？
Kafka目前最稳定的api是什么？我以为是0.8？
1条答案
按热度按时间y4ekin9u1#
支持轮询的消费者api仅在kafka 0.9中提供，kafka 0.9是最新发布的版本。对于早期版本，您必须使用kafka/core中kafka.consumer包下的旧使用者实现。