即墨网站建设即墨,wordpress 同分类评论调用,vc域名建站的网站,网站网站开发违法吗1、消息
Record#xff1a;Kafka 是消息引擎嘛#xff0c;这里的消息就是指 Kafka 处理的主要对象。
2、主题
Topic#xff1a;主题是承载消息的逻辑容器#xff0c;在实际使用中多用来区分具体的业务。在Kafka 中发布订阅的对象是 Topic。
3、分区
Partition#xf…1、消息
RecordKafka 是消息引擎嘛这里的消息就是指 Kafka 处理的主要对象。
2、主题
Topic主题是承载消息的逻辑容器在实际使用中多用来区分具体的业务。在Kafka 中发布订阅的对象是 Topic。
3、分区
Partition一个有序不变的消息序列。每个主题下可以有多个分区。业务上要保证顺序性将消息都写到一个分区由单个消费线程消费即可实现顺序消费。多个分区无法保证消息的全局顺序性。
4、消息位移
Offset表示分区中每条消息的位置信息是一个单调递增且不变的值。kafka 底层是追加写所以效率高所以单调递增一旦写到磁盘上后消息的位置就是固定的了。
5、副本
ReplicaKafka 中同一条消息能够被拷贝到多个地方以提供数据冗余这些地方就是所谓的副本。
副本还分为领导者副本和追随者副本。领导者副本对外提供服务生产者向领导者副本写消息消费者从领导者副本读消息追随者副本只是向领导者副本发起请求同步最新的消息。
为啥是追随者副本向领导者副本发起请求而不是领导者副本向追随者推送消息Kafka 不是 PUSH 模型而是 PULL 模型。
副本是在分区层级下的即每个分区可配置多个副本实现高可用。
6、生产者
Producer向主题发布新消息的应用程序可以向一个或者多个主题发送消息。
7、消费者
Consumer从主题订阅新消息的应用程序可以同时订阅多个主题的消息。 一个主题可以让若干个 consumer 消费若干个 consumer 组成一个 consumer group 一条消息只能被 consumer group 中一个 consumer 消费若干个 partition 被若干个 consumer 同时消费达到消费者高吞吐量。
8、消费者位移
Consumer Offset表征消费者消费进度每个消费者都有自己的消费者位移。正常都是顺序消费一遍的当然也可以重置消费者位移来达到业务目的。
9、消费者组
Consumer Group多个消费者实例共同组成的一个组同时消费多个分区以实现高吞吐。
10、重平衡
Rebalance。消费者组内某个消费者实例挂掉后其他消费者实例自动重新分配订阅主题分区的过程。Rebalance 是 Kafka 消费者端实现高可用的重要手段。
11、broker
服务代理节点Kafka 服务实例。 N 个组成一个 Kafka 集群通常一台机器部署一个 Kafka 实例一个实例挂了其他实例仍可以使用体现了高可用。 为什么 Kafka 不像 MySQL 那样允许追随者副本对外提供读服务
为什么kafka不支持主从分离 - 知乎
