恒生暑期 测开一面

强的老哥 mq都掌握这么熟练也来测开吗

Kafka发送消息接收的完整流程： 1. Producer发送消息：例如，一个在线商城的订单系统将新订单信息发送到Kafka集群。 2. 分区与路由：假设订单消息被路由到名为"orders"的主题，并根据订单ID的哈希值被分配到不同的分区。 3. 消息写入：Kafka Broker收到订单消息后，根据分区的配置将消息追加到对应分区的日志文件中。比如，订单消息被追加到分区1的日志文件中，并生成相应的索引。 4. 消息复制：为确保消息的持久性和高可用性，Kafka将分区1的数据复制到其他Broker的对应分区。例如，分区1的副本可能存在于Broker1、Broker2和Broker3上。 5. Consumer拉取消息：一个订单处理服务的Consumer从"orders"主题拉取消息。假设消费者从分区1的领导者拉取数据。 6. Consumer处理消息：订单处理服务收到订单消息后，执行订单处理逻辑，比如更新库存、生成发货通知等。 Kafka的特性： 1. 分布式与可扩展：Kafka集群中的各个Broker协同工作，处理大规模的订单数据流，从而保证系统的扩展性。 2. 消息持久性：订单消息被持久化到磁盘，即使Broker故障，也能保证消息不丢失。 3. 高吞吐量：Kafka设计用于处理大量的订单数据，能够以较低的延迟实现高吞吐量的消息处理。 4. 多订阅者模式：除了订单处理服务，可能还有其他服务需要消费订单消息，比如统计分析服务或者客户通知服务。 Kafka如何保证消息的顺序性和一致性可以通过以下数据例子进一步说明： - 顺序性：假设订单消息按照订单ID的哈希值被分区，那么同一个订单的消息将被分配到同一个分区，并且在该分区内保持顺序。因此，同一个订单的处理操作将保持顺序执行。 - 一致性：由于Kafka采用多副本机制，每个分区都有一个领导者负责处理写入请求，其他副本则同步领导者的数据。当领导者故障时，Kafka会进行自动的领导者选举，确保数据一致性和可用性。

控制 Producer 的配置方法： 1. **设置发送消息的速率**：`linger.ms=100` 2. **批处理大小设置**：`batch.size=1048576` 3. **设置最大发送速率**：`max.request.per.second=1000` 控制 Consumer 的配置方法： 1. **设置拉取间隔**：`fetch.min.bytes=1024` 2. **调整最大拉取记录数**：`max.poll.records=100` 3. **设置最大拉取间隔**：`fetch.max.wait.ms=500`

佬是什么部门