Kafka消費與位移

1. 前言 消息堆積是消費滯後(Lag)的一種表現形式，消息中間件服務端中所留存的消息與消費掉的消息之間的差值即爲消息堆積量，也稱之爲消費滯後(Lag)量。對於Kafka而言，消息被髮送至Topic中，而Topic又分成了多個分區(Partition)，每一個Partition都有一個預寫式的日誌文件，雖然Partition可以繼續細分爲若干個段文件(Segment)，但是對於上層應用來說可以將P

>>阅读原文<<