1 位移提交

​ kafka位移提交是指消费者消费消息之后，提交位移，将消息偏移量移到该次位移提交之后的位置，消费者位移提交具有下面特点：Consumer需要向Kafka记录自己的位移数据，这个汇报过程称为 提交位移(Committing Offsets) ，Consumer 需要为分配给它的每个分区提交各自的位移数据，位移提交的由Consumer端负责的，Kafka只负责保管__consumer_offsets，位移提交分为自动提交和手动提交，手工位移提交又分为同步提交和异步提交。

1.1 位移自动提交

​ 位移自动提交指的是Kafka Consumer 后台提交。开启位移自动提交需要配置两个参数：

##是否开启自动提交
enable.auto.commit=true
##配置自动提交间隔：Consumer端，默认是5秒
auto.commit.interval.ms

​ 下面是一个消费者配置了生产者自动提交和自动提交间隔时间的案例：

package com.dream21th.kafka