java - Kafka Consumer Properties 从最大偏移量读取

Question

我写了一个 Java Kafka Consumer。我想确定如何明确确保一旦 Kafka 消费者启动，它只读取生产者从那时起发送的消息，即它不应该读取生产者已经发送给 Kafka 的任何消息。谁能解释如何确保这一点？ :

这是我使用的属性的片段

Properties properties = new Properties();
properties.put("zookeeper.connect", zookeeperHost);
properties.put("group.id", group);
properties.put("auto.offset.reset","largest");
ConsumerConfig consumerConfig = new ConsumerConfig(properties);
consumerConnector = Consumer.createJavaConsumerConnector(consumerConfig);

9 月 14 日更新:

我正在使用以下属性，似乎消费者有时仍然从头开始阅读，有人能告诉我现在出了什么问题吗？

我正在使用 Kafka 版本 0.8.2

properties.put("auto.offset.reset","largest");
properties.put("auto.commit.enable","false");

Answer 1

根据上面的回答，似乎设置消费者属性的正确机制如下:

 properties.put("auto.offset.reset","largest");
 properties.put("auto.commit.enable","false");

这确保从最大偏移量读取