image

Kafka 开启 ACK 后的具体流程是怎样的？

Kafka 开启 ACK = request.required.asks参数配置Asks 这个参数是生产者客户端的重要配置，发送消息的时候就可设置这个参数。该参数有三个值可配置：0、1、All 。
image

说说Kafka水位(high watermark)与日志末端位移(log end offset)

水位或水印（ watermark ）一词，也可称为高水位 (high watermark) ，通常被用在流式处理领域（比如Apache Flink、Apache Spark等），以表征元素或事件在基于时间层面上的进度。
image

说说Kafka 基本原理和架构？

Kafka的架构一个典型的Kafka集群中包含若干Producer，若干broker（Kafka支持水平扩展，一般broker数量越多，集群吞吐率越高），若干Consumer Group，以及一个Zookeeper集群。
image

Kafka 如何做到高性能？

并行处理的支持Kafka中每个Topic都包含一个或多个Partition，不同Partition可位于不同节点。由于不同Partition可位于不同机器，因此可以充分利用集群优势，实现机器间的并行处理。
image

不同消息队列的选型和对比

技术选型一般从下面四个维度出发：功能、性能、稳定性、运维。功能优先级队列优先级队列不同于先进先出队列，优先级高的消息具备优先被消费的特权，这样可以为下游提供不同消息级别的保证。
image

如何保证消息不被重复消费？

kafka自带的消费机制kafka有个offset的概念，当每个消息被写进去后，都有一个offset，代表他的序号，然后consumer消费该数据之后，隔一段时间，会把自己消费过的消息的offset提交一下，代表我已经消费过了。
image

RabbitMQ 如何保证高可用的?

RabbitMQ基于主从模式实现高可用。RabbitMQ有三种模式：单机模式，普通集群模式，镜像集群模式。普通集群模式普通集群模式就是在多台机器上启动多个rabbitmq实例，每个机器启动一个。
image

Kafka如何保证高可用的?

kafka的一个基本架构：多个broker组成，一个broker是一个节点；你创建一个topic，这个topic可以划分成多个partition，每个partition可以存在于不同的broker上面，每个partition存放一部分数据。
image

为什么使用消息队列？

消息队列有什么作用？面对这些问题，我们围绕三个词回答就 OK 了：解耦、异步、削峰。消息队列是大型分布式系统实现高性能，高可用，可伸缩和最终一致性时不可缺少的中间件。