Kafka偏移量自动提交设置

1 应用场景

 

    消费kafka中的数据，使用的是自动提交偏移量的方式

   

2  配置项解答

 

 2.1  enable.auto.commit

    如果设置为 true，则开启了自动提交偏移量模式

 2.2 auto.offset.reset   

2.2.1 参数列表

 earliest：自动重置偏移量到最早的偏移量。

 latest：自动重置偏移量到最后一个

 none：如果没有找到该消费组以前的偏移量没有找到，就抛异常。 其他值：向消费者抛异常。    

 2.2.2 重点关注

 配置只有在Kafka中没有初始偏移量或当前偏移量在服务器中不存在时生效

 2.3   auto.commit.interval.ms

 

   默认 5s,消费者偏移量向Kafka提交的频率