6篇文章 · 4470字 · 1人关注
follower副本设计的原因 1.方便实现“Read-your-writes”：即只要写入了可以直接消费掉，不存在延迟2.方便实现单调读：单调...
生产者管理TCP连接 Kafka的通信使用TCP进行连接 生产者程序流程 1.构造生产者对象所需的参数对象。2.基于第一步的对象创建 Kafka...
生产者消息分区 Kafka 的消息组织方式实际上是三级结构：主题 - 分区 - 消息，每个消息只会在一个分区中出现。分区的作用就是提供负载均衡的...
顺序读写 一个partition其实是一个目录，而这个目录下面会有多个大小一样的数据文件segment（默认一个文件是500MB，可以手动去设置...
集群部署方案 操作系统选择 I/O模型选择 Kafka 客户端底层使用了 Java 的 selector，selector 在 Linux 上的...
术语总结 消息：Record。Kafka 是消息引擎嘛，这里的消息就是指 Kafka 处理的主要对象。主题：Topic。主题是承载消息的逻辑容器...
文集作者
