在kafka 0.8.2.0版本org.apache.kafka.clients.consumer.kafkaconsumer中，这个意图是吗
public Map<String, ConsumerRecords<K, V>> poll(long timeout) { return null; }
我应该使用哪个版本的0.8.x.x？
dgiusagp1#
我刚刚意识到，上面的方法和许多这样的方法不仅仅是用kafka的0.8-x.x版本实现的，它们只在0.9.0.0版本之后才可用！所以这意味着我应该使用以下方法：https://cwiki.apache.org/confluence/display/kafka/consumer+group+example作为如何写Kafka消费的参考！
1条答案
按热度按时间dgiusagp1#
我刚刚意识到，上面的方法和许多这样的方法不仅仅是用kafka的0.8-x.x版本实现的，它们只在0.9.0.0版本之后才可用！所以这意味着我应该使用以下方法：
https://cwiki.apache.org/confluence/display/kafka/consumer+group+example
作为如何写Kafka消费的参考！