From e4d198c890dbbec47afd74af668c24527dd3b500 Mon Sep 17 00:00:00 2001
From: rikako <496063163@qq.com>
Date: Mon, 20 Nov 2023 00:27:59 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20consumer=E7=9B=B8=E5=85=B3=E6=96=87?=
 =?UTF-8?q?=E6=A1=A3=E9=98=85=E8=AF=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 mq/kafka/kafka-尚硅谷.md | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/mq/kafka/kafka-尚硅谷.md b/mq/kafka/kafka-尚硅谷.md
index 97c57de..e6d3f67 100644
--- a/mq/kafka/kafka-尚硅谷.md
+++ b/mq/kafka/kafka-尚硅谷.md
@@ -362,6 +362,19 @@ kafka中的分区策略通过`partition.assignment.strategy`参数来进行配
 >
 > 在使用Sticky策略时，即使某台实例宕机，再平衡后存活实例被分配的分区仍然不会变，只是会将宕机实例负责的分区在存活实例之间尽可能均衡的分配
 
+##### offset
+在kafka集群中，会保存各个分区的消费情况，将分区针对每个消费者组的偏移量存储在__consumer_offsets主题中。默认情况下，__consumer_offsets采用key/value的形式来存储数据，key为`groupid+topic+分区号`,value则是当前offset的值。
+
+每个一段时间，kafka就会对该topic进行压缩。
+
+> #### kafka offset自动提交
+> kafka默认开启了自动提交功能，在使用kafka时可以专注消费的业务逻辑
+> 
+> 自动提交相关参数如下：
+> - `enable.auto.commit`:自动提交是否开启，该参数默认值为true
+> - `auto.commit.interval.ms`:自动提交默认的间隔时间为5s
+>
+> 在开启自动提交时，每次消费者调用poll接口时，都会检查是否距离上次提交的时间间隔已超过5s，若超过则执行自动提交逻辑。