CKafka(Cloud Kafka)是一個分布式、高吞吐量、高可擴展性的消息系統,****兼容開源 Kafka API(0.9、0.10版本)。CKafka 基于發布/訂閱模式,通過消息解耦,使生產者和消費者異步交互,無需彼此等待。CKafka 具有數據壓縮、同時支持離線和實時數據處理等優點,適用于日志壓縮收集、監控數據聚合等場景。
消息隊列CKafka 解耦生產和消費,提供可擴展、低延遲、高性能消息傳輸能力。
CKafka 能夠有效解耦生產者、消費者之間的關系,允許用戶獨立的擴展或修改生產消費之間的處理過程,只要確保它們遵守同樣的接口約束即可。因此,CKafka 可以平滑替換傳統消息中間件,在起到解耦生產者、消費者和緩存未處理消息的同時,CKafka 擁有更大的吞吐量、更強的分區復制機制和容錯機制。
在業務訪問量激增的情況下,系統應對突發的能力至關重要。但這種突發流量的情況并不常見,如果以業務訪問量峰值為標準投入資源則會導致資源的浪費。使用 CKafka 可以保證系統關鍵組件具有應對突發訪問壓力的能力,不會因為超負荷請求而導致系統完全崩潰。
由于消息的處理過程被解耦,只需要水平擴展處理過程,即可有效增加消息的入隊效率和處理效率,十分靈活。在具體實現上,CKafka 一個 Topic 可分多個 Partition, 并分布在一個或多個 Broker 上。一個消費者可訂閱其中一個或者多個 Partition,生產者負責將消息均衡分配到對應的 Partition。因此,增加 Broker 可以水平擴展集群,一般 Broker 數量越多,集群吞吐率越高。
CKafka 支持隊列、發布訂閱多種模式,Topic 支持分區(Partition)概念,不同分區可以落在不同 Broker, 有效增加吞吐量;此外,CKafka 支持發布/訂閱模式和多隊列模式,采用 Consumer Group 的策略,topic 在一個節點僅存儲一份數據,不同 Consumer Group 維護各自消費記錄數據。保證一次生產,多個 Consumer Group 消費的場景。





免責聲明:當前頁為 消息隊列CKafka產品信息展示頁,該頁所展示的 消息隊列CKafka產品信息及價格等相關信息均有企業自行發布與提供, 消息隊列CKafka產品真實性、準確性、合法性由店鋪所有企業完全負責。世界工廠網對此不承擔任何保證責任,亦不涉及用戶間因交易而產生的法律關系及法律糾紛,糾紛由會員自行協商解決。
友情提醒:世界工廠網僅作為用戶尋找交易對象,就貨物和服務的交易進行協商,以及獲取各類與貿易相關的服務信息的渠道。為避免產生購買風險,建議您在購買相關產品前務必確認供應商資質及產品質量。過低的價格、夸張的描述、私人銀行賬戶等都有可能是虛假信息,請您謹慎對待,謹防欺詐,對于任何付款行為請您慎重抉擇。
投訴方式:fawu@gongchang.com是處理侵權投訴的專用郵箱,在您的合法權益受到侵害時,請將您真實身份信息及受到侵權的初步證據發送到該郵箱,我們會在5個工作日內給您答復,感謝您對世界工廠網的關注與支持!