kafka java

<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>

java kafka是什麼，讓我們一起了解一下？

kafka是由Scala和Java編寫，Kafka是一種高吞吐量的分散式釋出訂閱訊息系統，它可以處理消費者在網站中的所有動作流資料，這些資料通常是由於吞吐量的要求而通過處理日誌和日誌聚合來解決。

kafka的簡單應用有哪些？

Broker : Kafka叢集包含一個或多個伺服器，這種伺服器被稱為broker。

Topic : 每條釋出到Kafka叢集的訊息都有一個類別，這個類別被稱為Topic。（物理上不同Topic的訊息分開儲存，邏輯上一個Topic的訊息雖然保存於一個或多個broker上但使用者只需指定訊息的Topic即可生產或消費資料而不必關心資料存於何處）

Partition : Partition是物理上的概念，每個Topic包含一個或多個Partition。

Producer : 負責釋出訊息到Kafka broker。

Consumer : 訊息消費者，向Kafka broker讀取訊息的客戶端。

Consumer Group : 每個Consumer屬於一個特定的Consumer Group（可為每個Consumer指定group name，若不指定group name則屬於預設的group）。

kafka如何應用？

通過對消費者專案的編寫，案例程式碼操作如下：

package com.jbit.util;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.springframework.kafka.annotation.KafkaListener;import org.springframework.stereotype.Component;import java.util.Optional;@Componentpublic class MyKafkaListener {    @KafkaListener(topics = {"message"})    public void listen(ConsumerRecord record) {        Optional kafkaMessage = Optional.ofNullable(record.value());        if (kafkaMessage.isPresent()) {            Object message = kafkaMessage.get();            System.out.println("資料接收完畢："+message);        }    }}