Kafka是一个消息订阅系统，通过接收消息顺序存储在本地磁盘，以便后端应用从kafka读取消息。本文基于Kafka...[作者空间]

Kakfa的集中leader选举过程 Kafka是分布式的消息分发系统，通过引入topic的概念来区分消息类型，引...[作者空间]

kafkaScheduler调度模块 KafkaScheduler作为broker进程的调度模块，提供对线程池的封...[作者空间]

Kafka的topic创建流程 Kafka的topic创建一般通过调用客户端接口实现。接口通过获取集群信息将创建t...[作者空间]

Kafka不同进程“沟通机制” Kafka服务的定位是一种高吞吐量的分布式消息订阅系统。服务再运行过程中，不同的进...[作者空间]