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?的内容。