Kafka除了具備消息隊列MQ的特性和使用場景外，它還有一個重要用途唆缴，就是做存儲層。 用kafka做存儲層黍翎，為什么呢面徽？一大堆可以做數(shù)據(jù)存儲的 M...

KafkaConsumer(消費者)每次調(diào)用 poll()方法，它總是返回由生產(chǎn)者寫入 Kafka但還沒有被消費者讀取過的記錄匣掸， 我們因 此可以...

應(yīng)用程序使用 KafkaConsumer向 Kafka 訂閱主題趟紊，并從訂閱的主題上接收消息 。 從 Kafka 讀取數(shù)據(jù)不同于從其他悄息系統(tǒng)讀取...

在之前的例子里(Kafka生產(chǎn)者——向 Kafka寫入數(shù)據(jù))碰酝， ProducerRecord 對象包含了目標(biāo)主題霎匈、鍵和值。 Kafka 的消息是...

不管是把 Kafka 作為消息隊列送爸、消息铛嘱、總線還是數(shù)據(jù)存儲平臺來使用 ，總是需要有一個可以往 Kafka 寫入數(shù)據(jù)的生產(chǎn)者和一個可以從 Kafk...

發(fā)布與訂閱消息系統(tǒng) 在正式討論Apache Kafka (以下簡稱Kafka)之前袭厂，先來了解發(fā)布與訂閱消息系統(tǒng)的概念墨吓， 并認(rèn)識這個系統(tǒng)的重要性。...