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