Kafka工作流程-消費過程分析

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