Kafka实现发布-订阅模式主要如下: 1. 通过 Topic 生产者(Producer)生产的消息会发送到特定的Topic。消费者(Consumer)会订阅特定的Topic。这样就可以实现不同的生产者和消费者之间的解耦。 2. Co...

Kafka Consumer Kafka 有消费组的概念，每个消费者只能消费所分配到的分区的消息，每一个分区只能被一个消费组中的一个消费者所消费，所以同一个消费组中消费者的数量如果超过了分区的数量，将...

Start:启动Spring容器时,自动启动Dubbo的Provider Register: Dubbo的Provider在启动后会去注册中心注册内容.注册的内容包括:IP、端口、接口列表（接口类、方法）、版本、Provider的协议. Subscr...

consumer group中的消费者与topic下的partion重新匹配的过程 何时会产生rebalance： consumer group中的成员个数发生变化 consumer消费超时 group订阅的topic个数发生变化 group订阅的topic的分...

pull模式： 根据consumer的消费能力进行数据拉取，可以控制速率 可以批量拉取、也可以单条拉取 可以设置不同的提交方式，实现不同的传输语 缺点：如果kafka没有数据，会导致consumer空循环，消...

五个角色： 注册中心registry：服务注册与发现 服务提供者provider：暴露服务服务 消费者consumer：调用远程服务 监控中心monitor：统计服务的调用次数和调用时间 容器container：服务允许容器 ...