《kafka》专题

本文向大家介绍Kafka分区分配的概念？相关面试题，主要包含被问及Kafka分区分配的概念？时的应答技巧和注意事项，需要的朋友参考一下 一个topic多个分区，一个消费者组多个消费者，故需要将分区分配个消费者(roundrobin、range)  

本文向大家介绍Kafka有内部的topic吗？如果有是什么？有什么所用？相关面试题，主要包含被问及Kafka有内部的topic吗？如果有是什么？有什么所用？时的应答技巧和注意事项，需要的朋友参考一下 __consumer_offsets,保存消费者offset

本文向大家介绍kafka基础架构相关面试题，主要包含被问及kafka基础架构时的应答技巧和注意事项，需要的朋友参考一下 1）Producer ：消息生产者，就是向kafka broker发消息的客户端； 2）Consumer ：消息消费者，向kafka broker取消息的客户端； 3）Consumer Group （CG）：消费者组，由多个consumer组成。消费者组内每个消费者负责消费不同分

本文向大家介绍Kafka的那些设计让它有如此高的性能？相关面试题，主要包含被问及Kafka的那些设计让它有如此高的性能？时的应答技巧和注意事项，需要的朋友参考一下 分区，顺序写磁盘，0-copy

本文向大家介绍kafka相关概念与消费模型相关面试题，主要包含被问及kafka相关概念与消费模型时的应答技巧和注意事项，需要的朋友参考一下 broker：kafka集群中的一个节点 topic：主题是kafka的逻辑上的队列 partition：一个topic可以包含一个或多个partition，每个partition的消息数据都是单独存储的，offset也是单独维护的，partition内部消息

本文向大家介绍如何做的消息队列选型，为什么选择kafka？相关面试题，主要包含被问及如何做的消息队列选型，为什么选择kafka？时的应答技巧和注意事项，需要的朋友参考一下 kafka和rocketmq吞吐量可达百万级，比activemq、rabbitmq要高一个数量级 kafka和rocketmq都是分布式架构，高可用 kafka和rocketmq都是毫秒级低延时，rocketmq甚至到微秒级 r

本文向大家介绍kafka的消息存储？相关面试题，主要包含被问及kafka的消息存储？时的应答技巧和注意事项，需要的朋友参考一下 kafka的消息存储在磁盘上，一个kafka topic分为一个或多个partition，每个partition单独存储自己的消息数据 partition将数据记录到.log文件中，为了避免文件过大影响查询效率，将文件分段处理 记录消息到.log文件中的同时，会记录消息o

本文向大家介绍kafka高可用原理？相关面试题，主要包含被问及kafka高可用原理？时的应答技巧和注意事项，需要的朋友参考一下 broker启动会尝试向zookeeper创建临时节点：/controller，第一个broker选举成功成为集群的controller，其余节点都会在/controller注册watcher监控controller状态；当controller挂掉，所有broker感知到

本文向大家介绍kafka如何保证不丢失消息？相关面试题，主要包含被问及kafka如何保证不丢失消息？时的应答技巧和注意事项，需要的朋友参考一下 复制因子：创建topic的时候指定复制因子大于1时，一个分区被分配到一个broker上，同时会在其他broker上维护一个分区副本； isr列表：分区及其副本分别为leader和follower，leader对外提供读写服务，follower会向leade

本文向大家介绍kafka高性能原因是什么？相关面试题，主要包含被问及kafka高性能原因是什么？时的应答技巧和注意事项，需要的朋友参考一下 零拷贝、利用操作系统页缓存、磁盘顺序写 kafka零拷贝原理 分区、分段、建立索引 生产者、消费者批处理

本文向大家介绍简述Kafka的日志目录结构相关面试题，主要包含被问及简述Kafka的日志目录结构时的应答技巧和注意事项，需要的朋友参考一下 每个partition一个文件夹，包含四类文件.index .log .timeindex leader-epoch-checkpoint .index .log .timeindex 三个文件成对出现 前缀为上一个segment的最后一个消息的偏移 log文

本文向大家介绍Kafka目前有那些内部topic，它们都有什么特征？各自的作用又是什么？相关面试题，主要包含被问及Kafka目前有那些内部topic，它们都有什么特征？各自的作用又是什么？时的应答技巧和注意事项，需要的朋友参考一下 consumer_offsets 以下划线开头，保存消费组的偏移

本文向大家介绍Kafka中的幂等是怎么实现的相关面试题，主要包含被问及Kafka中的幂等是怎么实现的时的应答技巧和注意事项，需要的朋友参考一下 pid+序号实现，单个producer内幂等？ 扩展问题： Kafka中有那些地方需要选举？这些地方的选举策略又有哪些？ 失效副本是指什么？有那些应对措施？ 多副本下，各个副本中的HW和LEO的演变过程 为什么Kafka不支持读写分离？ Kafka在可靠性

本文向大家介绍Kafka中的ISR、AR又代表什么？ISR的伸缩又指什么相关面试题，主要包含被问及Kafka中的ISR、AR又代表什么？ISR的伸缩又指什么时的应答技巧和注意事项，需要的朋友参考一下 ISR:In-Sync Replicas 副本同步队列 AR:Assigned Replicas 所有副本 ISR是由leader维护，follower从leader同步数据有一些延迟（包括延迟时间r

本文向大家介绍如果我指定了一个timestamp，Kafka怎么查找到对应的消息？相关面试题，主要包含被问及如果我指定了一个timestamp，Kafka怎么查找到对应的消息？时的应答技巧和注意事项，需要的朋友参考一下 1.通过文件名前缀数字x找到该绝对offset 对应消息所在文件 2.offset-x为在文件中的相对偏移 3.通过index文件中记录的索引找到最近的消息的位置 4.从最近位置开