所谓Kafka 其实就是由 Linkedin 公司开发的，它是一个分布式的，支持多分区、多副本，基于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软件。
标签： 什么
本文地址：https://www.lifejia.cn/news/63040.html
免责声明：本站内容仅用于学习参考，信息和图片素材来源于互联网，如内容侵权与违规，请联系我们进行删除，我们将在三个工作日内处理。联系邮箱：cloudinto#qq.com（把#换成@）
