Kafka消費過程分析

kafka提供了兩套consumer API:高級Consumer API和低級API。 1 消費模型        消息由生產者發佈到Kafka集羣后,會被消費者消費。消息的消費模型有兩種:推送模型(push)和拉取模型(pull)。 基於推送模型(push)的消息系統,由消息代理記錄消費者的消費狀態。消息代理在將消息推送到消費者後,標記這條消息爲已消費,但這種方式無法很好地保證消息被處理。比如
相關文章
相關標籤/搜索