記一次kafka消息實際操作記錄

消息結構(生產者微服務+消費者微服務) kafka的消息實現由Producer生產消息,Consumer消費消息構成。 生產者流程 Producer生產消息採用推(push)模式發佈到Broker(kafka服務器),每條消息都被追加(append)到Partition(分區)中,屬於順序寫磁盤(順序寫磁盤效率比隨機寫內存要高,保障kafka吞吐率)。 producer寫入消息流程如下 消費者流程
相關文章
相關標籤/搜索