kafka消費的過程

消費模型 消息由生產者發佈到Kafka集羣后，會被消費者消費。消息的消費模型有兩種：推送模型（push）和拉取模型（pull）。 基於推送模型（push）的消息系統，由消息代理記錄消費者的消費狀態。消息代理在將消息推送到消費者後，標記這條消息爲已消費，但這種方式無法很好地保證消息被處理。比如，消息代理把消息發送出去後，當消費進程掛掉或者由於網絡原因沒有收到這條消息時，就有可能造成消息丟失（因爲消息

>>阅读原文<<