本文将简要介绍apachekafka的基本概念。
简单来说,apachekafka是为分布式高吞吐量系统设计的。它往往可以很好地替代传统的消息代理。与其他消息传递系统相比,Kafka具有更好的吞吐量、内置的分区、复制和固有的容错能力,非常适合大规模的消息处理应用,我将介绍一些关于它的基本概念。
代理
卡夫卡服务器。
消息
通过卡夫卡从生产者发送给消费者的信息。
生产者
发送消息的应用程序。
消费者
接收消息的应用程序。
卡夫卡集群
由一个或多个服务器(代理)组成。
主题
主题是一个应用程序存储和发布邮件的类别名称。所有卡夫卡的信息都被组织成主题。生产者应用程序向主题写入数据,wap自助建站,消费者应用程序从主题读取数据。
发布到集群的消息将留在集群中,海淘返现,直到保留期结束。
主题分区
主题被划分为多个分区,这些分区允许在多个代理中拆分数据。
每个分区都是有序的,大数据查询,不可变的消息序列,不断地附加到。分区中的每个消息都分配了一个称为偏移量的顺序id号,物联网是啥,该偏移量唯一地标识分区中每个消息,如下所示:
生产者将数据发布到他们选择的主题,有三种方法可以决定发布的消息属于哪个分区:
消费者组
消费者可以加入称为消费者组的组。使用者组包括订阅特定主题的已处理使用者集。组中的每个使用者都被分配一组分区给来自的使用者。它们将接收来自主题中不同分区子集的消息。Kafka保证一条消息只能被组中的一个使用者读取
分区数和使用者数之间的关系有三种可能的场景:
好的,以上是Apache Kafka的基本概念简介,物联网开发,希望它能帮助你对阿帕奇·卡夫卡有所了解。