《kafka》专题

本文向大家介绍Kafka 缺点？相关面试题，主要包含被问及Kafka 缺点？时的应答技巧和注意事项，需要的朋友参考一下 由于是批量发送，数据并非真正的实时； 对于mqtt协议不支持； 不支持物联网传感数据直接接入； 仅支持统一分区内消息有序，无法实现全局消息有序； 监控不完善，需要安装插件； 依赖zookeeper进行元数据管理；

本文向大家介绍谈一谈 Kafka 的再均衡相关面试题，主要包含被问及谈一谈 Kafka 的再均衡时的应答技巧和注意事项，需要的朋友参考一下 在Kafka中，当有新消费者加入或者订阅的topic数发生变化时，会触发Rebalance(再均衡：在同一个消费者组当中，分区的所有权从一个消费者转移到另外一个消费者)机制，Rebalance顾名思义就是重新均衡消费者消费。Rebalance的过程如下： 第一

本文向大家介绍Kafka 消息格式的演变清楚吗？相关面试题，主要包含被问及Kafka 消息格式的演变清楚吗？时的应答技巧和注意事项，需要的朋友参考一下 用 Kafka这么久，从来都没去了解 Kafka 消息的格式。今天特意去网上搜索了以下，发现这方面的资料真少，很多资料都是官方文档的翻译；而且 Kafka消息支持压缩，对于压缩消息的格式的介绍更少。基于此，本文将以图文模式介绍 Kafka 0.7.

本文向大家介绍Kafka新建的分区会在哪个目录下创建相关面试题，主要包含被问及Kafka新建的分区会在哪个目录下创建时的应答技巧和注意事项，需要的朋友参考一下 我们知道，在启动 Kafka 集群之前，我们需要配置好 参数，其值是 Kafka 数据的存放目录，这个参数可以配置多个目录，目录之间使用逗号分隔，通常这些目录是分布在不同的磁盘上用于提高读写性能。当然我们也可以配置 参数，含义一样。只需要设

本文向大家介绍kafka producer 打数据，ack 为 0， 1， -1 的时候代表啥， 设置 -1 的时候，什么情况下，leader 会认为一条消息 commit了？相关面试题，主要包含被问及kafka producer 打数据，ack 为 0， 1， -1 的时候代表啥， 设置 -1 的时候，什么情况下，leader 会认为一条消息 commit了？时的应答技巧和注意事项，需要的朋友参

本文向大家介绍为什么Kafka不支持读写分离？相关面试题，主要包含被问及为什么Kafka不支持读写分离？时的应答技巧和注意事项，需要的朋友参考一下 在 Kafka 中，生产者写入消息、消费者读取消息的操作都是与 leader 副本进行交互的，从 而实现的是一种主写主读的生产消费模型。 Kafka 并不支持主写从读，因为主写从读有 2 个很明 显的缺点: (1)数据一致性问题。数据从主节点转到从节点

本文向大家介绍Kafka中的分区器、序列化器、拦截器是否了解？它们之间的处理顺序是什么？相关面试题，主要包含被问及Kafka中的分区器、序列化器、拦截器是否了解？它们之间的处理顺序是什么？时的应答技巧和注意事项，需要的朋友参考一下 拦截器->序列化器->分区器

本文向大家介绍kafka如何实现延迟队列？相关面试题，主要包含被问及kafka如何实现延迟队列？时的应答技巧和注意事项，需要的朋友参考一下 Kafka并没有使用JDK自带的Timer或者DelayQueue来实现延迟的功能，而是基于时间轮自定义了一个用于实现延迟功能的定时器（SystemTimer）。JDK的Timer和DelayQueue插入和删除操作的平均时间复杂度为O(nlog(n))，并不

本文向大家介绍kafka中的 zookeeper 起到什么作用，可以不用zookeeper么？相关面试题，主要包含被问及kafka中的 zookeeper 起到什么作用，可以不用zookeeper么？时的应答技巧和注意事项，需要的朋友参考一下 zookeeper 是一个分布式的协调组件，早期版本的kafka用zk做meta信息存储，consumer的消费状态，group的管理以及 offset的值

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

本文向大家介绍什么是kafka？相关面试题，主要包含被问及什么是kafka？时的应答技巧和注意事项，需要的朋友参考一下 Kafka是分布式发布-订阅消息系统，它最初是由LinkedIn公司开发的，之后成为Apache项目的一部分，Kafka是一个分布式，可划分的，冗余备份的持久性的日志服务，它主要用于处理流式数据。

本文向大家介绍为什么要使用 kafka，为什么要使用消息队列？相关面试题，主要包含被问及为什么要使用 kafka，为什么要使用消息队列？时的应答技巧和注意事项，需要的朋友参考一下 缓冲和削峰：上游数据时有突发流量，下游可能扛不住，或者下游没有足够多的机器来保证冗余，kafka在中间可以起到一个缓冲的作用，把消息暂存在kafka中，下游服务就可以按照自己的节奏进行慢慢处理。 解耦和扩展性：项目开始的

本文向大家介绍Kafka中有那些地方需要选举？这些地方的选举策略又有哪些？相关面试题，主要包含被问及Kafka中有那些地方需要选举？这些地方的选举策略又有哪些？时的应答技巧和注意事项，需要的朋友参考一下 kafka在所有broker中选出一个controller，所有Partition的Leader选举都由controller决定。controller会将Leader的改变直接通过RPC的方式（比

本文向大家介绍kafka follower如何与leader同步数据？相关面试题，主要包含被问及kafka follower如何与leader同步数据？时的应答技巧和注意事项，需要的朋友参考一下 Kafka的复制机制既不是完全的同步复制，也不是单纯的异步复制。完全同步复制要求All Alive Follower都复制完，这条消息才会被认为commit，这种复制方式极大的影响了吞吐率。而异步复制方式

本文向大家介绍kafka 为什么那么快？相关面试题，主要包含被问及kafka 为什么那么快？时的应答技巧和注意事项，需要的朋友参考一下 Cache Filesystem Cache PageCache缓存 顺序写 由于现代的操作系统提供了预读和写技术，磁盘的顺序写大多数情况下比随机写内存还要快。 Zero-copy 零拷技术减少拷贝次数 Batching of Messages 批量量处理。合并小