排序
Kafka是pull?push?优劣势分析
pull模式: 根据consumer的消费能力进行数据拉取,可以控制速率 可以批量拉取、也可以单条拉取 可以设置不同的提交方式,实现不同的传输语 缺点:如果kafka没有数据,会导致consumer空循环,消...
简述Kafka的rebalance机制
consumer group中的消费者与topic下的partion重新匹配的过程 何时会产生rebalance: consumer group中的成员个数发生变化 consumer消费超时 group订阅的topic个数发生变化 group订阅的topic的分...
Kafka的消费队列的原理是什么?
Kafka实现发布-订阅模式主要如下: 1. 通过 Topic 生产者(Producer)生产的消息会发送到特定的Topic。消费者(Consumer)会订阅特定的Topic。这样就可以实现不同的生产者和消费者之间的解耦。 2. Co...
Dubbo的整体架构设计及分层
五个角色: 注册中心registry:服务注册与发现 服务提供者provider:暴露服务服务 消费者consumer:调用远程服务 监控中心monitor:统计服务的调用次数和调用时间 容器container:服务允许容器 ...
dubbo的工作流程
Start:启动Spring容器时,自动启动Dubbo的Provider Register: Dubbo的Provider在启动后会去注册中心注册内容.注册的内容包括:IP、端口、接口列表(接口类、方法)、版本、Provider的协议. Subscr...
Kafka Consumer消费消息和Rebalance机制
Kafka Consumer Kafka 有消费组的概念,每个消费者只能消费所分配到的分区的消息,每一个分区只能被一个消费组中的一个消费者所消费,所以同一个消费组中消费者的数量如果超过了分区的数量,将...