消費位點
更新時間 2023-05-13 17:04:39
最近更新時間: 2023-05-13 17:04:39
分享文章
每個 Topic 會有多個分區,每個分區會統計當前消息的總條數,這個稱為最大位點 MaxOffset。Kafka Consumer 會按順序依次消費分區內的每條消息,記錄已經消費了的消息條數,稱為ConsumerOffset。
剩余的未消費的條數(也稱為消息堆積量) = MaxOffset - ConsumerOffset