排序
面试题:RocketMQ 的事务消息有什么缺点?你还了解过别的事务消息实现吗?
RocketMQ 的事务消息机制是其核心特性之一,用于解决分布式场景下的消息一致性问题。尽管 RocketMQ 的事务消息功能非常强大,但它也存在一些缺点。同时,除了 RocketMQ,Kafka 也提供了事务消息...
面试题:说一下 Kafka 中关于事务消息的实现?
Kafka 的事务消息机制是为了确保生产者发送的消息能够以原子性的方式写入多个分区,或者在消费和生产的组合操作中实现端到端的精确一次语义(Exactly-Once Semantics)。以下是 Kafka 事务消息...
面试题:你了解 Kafka 中的时间轮实现吗?
Kafka 中的时间轮(Timing Wheel)是一种高效管理定时任务的机制,主要用于延迟操作,如延迟生产、延迟拉取等。时间轮的核心思想是通过一个环形数组来表示时间槽,每个槽对应一个时间间隔,任务...
面试题:Kafka的索引设计有什么亮点?
Kafka 的索引设计是其高性能和高效存储的关键之一。 Kafka 使用了两类索引来加速消息的查找和读取:偏移量索引(Offset Index) 和 时间戳索引(Timestamp Index)。 在面试中,如果被问到“K...
面试题:看过源码?那说说 Kafka 控制器事件处理全流程?
Kafka 控制器(Controller)是 Kafka 集群的核心组件之一,负责管理集群的元数据和协调分布式操作。控制器的主要职责包括分区 Leader 选举、分区重新分配、Broker 上下线处理等。在面试中,如果...
面试题:Kafka 中 Zookeeper 的作用?
在 Kafka 的早期版本中,Zookeeper 是一个核心组件,负责管理 Kafka 集群的元数据和协调分布式一致性。 虽然 Kafka 从 2.8.0 版本开始引入了 KRaft 模式(Kafka Raft Metadata Mode),逐步摆脱...
面试题:Kafka为什么要抛弃 Zookeeper?
Kafka 从 2.8.0 版本开始引入了 Kafka Raft Metadata Mode(KRaft),逐步摆脱了对 Zookeeper 的依赖。这一变化是 Kafka 架构演进的重要里程碑。在面试中,如果被问到“Kafka 为什么要抛弃 Zook...
面试题:看过源码?那说说 Kafka 处理请求的全流程?
Kafka 是一个分布式流处理平台,广泛用于构建实时数据管道和流应用。在面试中,如果被问到 Kafka 处理请求的全流程,可以从以下几个方面进行详细阐述: 1. 请求接收与分发 Kafka 使用基于 React...
面试题:RabbitMQ 中无法路由的消息会去到哪里?
在 RabbitMQ 中,如果消息无法被路由到任何队列(例如没有绑定队列或路由键不匹配),消息的处理方式取决于交换机的配置。以下是消息无法路由时的可能去向: 1. 默认行为:消息被丢弃 如果...
面试题:RabbitMQ 中消息什么时候会进入死信交换机?
在 RabbitMQ 中,死信交换机(Dead Letter Exchange, DLX) 是一种特殊的交换机,用于处理无法被正常消费的消息。当消息满足某些条件时,它会被重新发布到死信交换机,进而路由到死信队列...