Kafka中auto.offset.reset配置项参数为earliest或者latest的区别

Kafka中auto.offset.reset配置项参数为earliest/或者latest的区别 工作中接触到通过kafka拉数据的需求，了解到offset.reset配置项，记录一下

相关代码段：

    consumerGroup.setConsumer(`testKafka${new Date().getTime()}`,
     Config.KafkaInput, true, OFFSET.eariest,    //latest和earliest的设置
    (msg) => {
        console.log(JSON.stringify(msg));
    }, (err) => {
        console.log("Kafka Error:" + err);
    }
    );

auto.offset.reset关乎kafka数据的读取，常用的二个值是latest和earliest

latest和earliest区别

1、earliest 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费

2、latest 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，消费新产生的该分区下的数据

提交过offset，latest和earliest没有区别，但是在没有提交offset情况下，用latest直接会导致无法读取旧数据。

如果kafka只接收数据，从来没来消费过，程序一开始不要用latest，不然以前的数据就接收不到了。应当先earliest，然后二者都可以

相关参数配置和解释（来源于网络）

原文链接：https://blog.csdn.net/weixin_44874132/article/details/117625895

  props.put(ConsumerConfig.GROUP_ID_CONFIG,groupId);//消费组id
  props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");//latest,earliest
  props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG,false);

在auto.offset.reset标志位为earliest/或者latest，创建的第一个消费者都将在enable.auto.commit的基础之上进行继续消费（如果enable.auto.commit=TRUE，则同一个消费者重启之后不会重复消费之前消费过的消息；enable.auto.commit=FALSE，则消费者重启之后会消费到相同的消息）

auto.offset.reset是对新的消费者而言（不同的groupId对应着不同的消费者）
在auto.offset.reset=earliest情况下，新的消费者（消费者二）将会从头开始消费Topic下的消息，即从offset=0的位置开始消费。

在auto.offset.reset=latest情况下，新的消费者将会从其他消费者最后消费的offset处开始消费Topic下的消息，比如上一个消费者提交的offset是30，则另一个消费组会开始从offset为30的位置开始消费。