kafka的消息分發策略和如何保存消費端的消費位置

關於消息分發 kafka 消息分發策略java 消息是 kafka 中最基本的數據單元,在 kafka 中,一條消息由 key、value 兩部分構成,在發送一條消息時,咱們能夠指定這個 key,那麼 producer 會根據 key 和 partition 機制來判斷當前這條消息應該發送並存儲到哪一個 partition 中。咱們能夠根據須要進行擴展 producer 的 partition 機
相關文章
相關標籤/搜索