Kafka 是基于Zookeeper 的分布式消息流平臺,它同時也是一款開源的基于發(fā)布訂閱模式的消息引擎系統(tǒng)。Kafka的主要功能包括生產(chǎn)者發(fā)送消息給kafka服務(wù)器、消費者從kafka服務(wù)器讀取消息、Kafka服務(wù)器依托zookeeper集群進(jìn)行服務(wù)的協(xié)調(diào)管理。
1、生產(chǎn)者發(fā)送消息給kafka服務(wù)器
發(fā)送消息主要有3種方式:發(fā)送并忘記(fire-and-forget)、同步發(fā)送、異步發(fā)送。
2、消費者從kafka服務(wù)器讀取消息
需要從Kafka讀取數(shù)據(jù)的應(yīng)用程序使用KafkaConsumer訂閱Kafka主題,并從這些主題接收消息。從Kafka讀取數(shù)據(jù)與從其他消息系統(tǒng)讀取數(shù)據(jù)有一點不同,其中包含了一些獨特的概念和思想。如果不先理解這些概念,就很難理解如何使用消費者API。將首先解釋一些重要的概念,然后通過一些示例展示使用消費者api實現(xiàn)需求不同的應(yīng)用程序的不同方式。
3、Kafka服務(wù)器依托zookeeper集群進(jìn)行服務(wù)的協(xié)調(diào)管理
kafka是通過zookeeper來管理集群。kafka軟件包內(nèi)雖然包括了一個簡版的zookeeper,但是感覺功能有限。在生產(chǎn)環(huán)境下,建議還是直接下載官方zookeeper軟件。
以上就是什么是kafka?的內(nèi)容。