八股---9.消息中间件
Kafka
Kafka是如何保证消息不丢失?
候选人:
Kafka保证消息不丢失的措施包括:
生产者使用异步回调发送消息,设置重试机制应对网络问题。
在Broker中通过复制机制,设置
acks
参数为all
,确保消息在所有副本中都得到确认。消费者手动提交消费成功的offset,避免自动提交可能导致的数据丢失或重复消费。
Kafka中消息的重复消费问题如何解决?
候选人:
通过以下方法解决Kafka中的重复消费问题:
禁用自动提交offset,手动控制offset提交时机。
确保消息消费的幂等性,例如通过唯一主键或分布式锁。
Kafka是如何保证消费的顺序性?
候选人:
Kafka默认不保证消息顺序性,但可以通过以下方法实现:
将消息存储在同一个分区,通过指定分区号或相同的业务key来实现。
Kafka的高可用机制了解吗?
候选人:
Kafka的高可用性主要通过以