Kafka消费组，创建消费组时设置offset为0答案

【问题标题】：Kafka consumer group, set offset to 0 when consumer group is createdKafka消费组，创建消费组时设置offset为0
【发布时间】：2019-08-23 23:08:57
【问题描述】：

我正在用 Java 像这样创建一个新的 Kafka 消费者（为简洁起见，省略了一些代码）

    final Properties props = new Properties();
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "group2");

    final Consumer<Long, String> consumer = new KafkaConsumer<>(props);
    consumer.subscribe(Collections.singletonList("topicname"));

这也会自动创建消费者组，以防它尚不存在。问题是这个消费者组的偏移量不是在话题的开头，而是在结尾。

如何确保在创建组时偏移量为 0（但不是其他情况）？我不想手动跟踪偏移量，如果消费者组尚不存在，则在创建消费者时将其设置为 0。

【问题讨论】：

标签： java apache-kafka kafka-consumer-api

【解决方案1】：

如果您没有在consumer config 中为auto.offset.reset 指定任何值，则默认为“最新”偏移量。

如果要从偏移量 0 开始消费，则需要将其设置为“最早”：

props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

【讨论】：