- Kafka集群 內(nèi)容精選 換一換
-
使用MirrorMaker進(jìn)行不同Kafka集群間的數(shù)據(jù)同步,可以確保Kafka集群的可用性和可靠性。 Kafka客戶端參數(shù)配置建議 Kafka客戶端的配置參數(shù)非常多,本章分別提供Producer和Consumer中常用的幾個(gè)參數(shù)配置。 Kafka客戶端使用規(guī)范 介紹Kafka的Consumer來(lái)自:專題Kafka的消息系統(tǒng)架構(gòu)主要分為兩個(gè)部分:消息生產(chǎn)者和消息消費(fèi)者。在Kafka中,消息生產(chǎn)者主要負(fù)責(zé)將消息發(fā)送至Kafka集群,而消息消費(fèi)者則負(fù)責(zé)讀取Kafka中存儲(chǔ)的消息。 了解詳情 Kafka的消息系統(tǒng)如何實(shí)現(xiàn) Kafka的消息系統(tǒng)是由一組Broker來(lái)共同實(shí)現(xiàn)的,每個(gè)Broke來(lái)自:專題
- Kafka集群 相關(guān)內(nèi)容
-
個(gè)主題,Kafka集群保留一個(gè)用于縮放、并行化和容錯(cuò)性的分區(qū)(Partition)。每個(gè)分區(qū)是一個(gè)有序、不可變的消息序列,并不斷追加到提交日志文件。分區(qū)的消息每個(gè)也被賦值一個(gè)稱為偏移順序(Offset)的序列化編號(hào)。 各模塊功能介紹如下: Broker 在Kafka集群上一個(gè)服務(wù)器稱為一個(gè)Broker。來(lái)自:專題
- Kafka集群 更多內(nèi)容
-
華為云計(jì)算 云知識(shí) 什么是分布式消息服務(wù)Kafka 什么是分布式消息服務(wù)Kafka 時(shí)間:2020-09-17 14:49:58 Kafka是一個(gè)擁有高吞吐、可持久化、可水平擴(kuò)展,支持流式數(shù)據(jù)處理等多種特性的分布式消息流處理中間件,采用分布式消息發(fā)布與訂閱機(jī)制,在日志收集、流式數(shù)來(lái)自:百科
層業(yè)務(wù)。 消息過(guò)濾 根據(jù)消息標(biāo)簽對(duì)可消費(fèi)的消息進(jìn)行過(guò)濾。 消息回溯 通過(guò)指定時(shí)間或位置,對(duì)已經(jīng)消費(fèi)過(guò)的消息進(jìn)行重新消費(fèi)。 定時(shí)/延時(shí)消息 在消息生產(chǎn)時(shí)間(當(dāng)前時(shí)間)之后的指定時(shí)間點(diǎn)投遞給消費(fèi)組消費(fèi)。 分布式消息服務(wù)支持一鍵在線擴(kuò)容,不影響上層業(yè)務(wù)。 消息過(guò)濾 根據(jù)消息標(biāo)簽對(duì)可消費(fèi)的消息進(jìn)行過(guò)濾。來(lái)自:專題