22篇文章 · 18623字 · 3人关注
-
(11)如何确定合适分区数(1)
Kafka高吞吐量，就是通过partition将topic中消息存到Kafka集群不同broker中。partition并行度调优最小单元 理论...
-
(11)Kafka分区数只加不减(2)topic创建后，可修改分区数、配置等，功能由kafka-topics.sh脚本中alter指令提供。 一、如何增加主题分区数？ 例：主题top...
-
(10)Consumer多线程实例(2)Kafka 0.9推了Java版本consumer(替换Scala版本)，优化coordinator摆脱对zk依赖。 Consumer(非线程安...
-
(6)哪些场景重复消费或丢失(2)概要：1、位移设置：定期自动提交、周期时间 2、消息丢失 3、手动提交：1）同步 2）异步 ----------------------...
-
(10)消费者
1、消费组：分区只能被组中一个消费者消费；消费者>分区个数，有空闲 2、分区策略：1)界限分配(默认) 2)轮询分配 3)粘性分配(均匀、尽...
-
(9)拦截器、序列化器、分区器处理顺序生产者客户端：主线程和 Sender 线程 1、主线程：由 KafkaProducer 创建消息，通过拦截器、序列化器和分区器后缓存到消息累加器...
-
(8)Kafka怎么体现消息顺序性概要：2：方案1、2、3，消费多线程只串行，有点鸡肋了 一、Kafka只能保证分区内消息顺序有序，无法保证全局有序 生产者：通过分区leader...
-
(7)ISR、AR代表什么？ISR伸缩是什么？AR(Assigned Repllicas)：分区中所有副本统称 ISR(In-Sync Replicas)：与leader副本保持一定程度同步...
-
(4)kafka存储机制概要：1、topic中partition存储分布 2、partiton中文件存储方式 3、partiton中segment文件存储结构：组成、命...
