面试题答案
一键面试1. 确认机制（acks 参数）
- acks=0：生产者发送消息后，不需要等待 Kafka 集群的任何确认。消息被立即添加到 socket 缓冲区并认为已发送成功。这种情况下，消息发送速度最快，但可靠性最低，因为如果 Kafka 集群未收到消息，生产者不会知晓。
- acks=1：生产者发送消息后，只要 Kafka 的 leader 副本成功接收消息，就会向生产者发送确认。如果在 leader 副本将消息写入日志前发生故障，消息可能丢失。
- acks=all（或 acks=-1）：生产者发送消息后，需要等待所有同步副本（ISR 中的副本）都成功接收消息，才会收到确认。这提供了最高的消息可靠性，但可能会因为等待所有副本确认而降低性能。
2. 重试机制（retries 参数）
- 参数作用：当消息发送失败时，生产者可以根据
retries参数指定的次数进行重试。例如网络瞬时故障等原因导致的消息发送失败，通过重试有可能成功发送。 - 注意事项：如果设置了较大的重试次数，并且消息发送失败是由于永久性错误（如 topic 不存在且无法自动创建），可能会导致不必要的重试消耗资源。同时，需要结合
retry.backoff.ms参数设置每次重试的间隔时间，避免过于频繁的重试。
3. 生产者拦截器
- 自定义拦截器：可以通过实现
ProducerInterceptor接口来自定义生产者拦截器。在消息发送前，拦截器可以对消息进行修改、添加元数据等操作。例如添加消息发送时间戳，以便后续分析消息延迟等问题。 - 异常处理：拦截器还可以在消息发送失败时进行一些处理，如记录错误日志等，有助于排查消息发送失败的原因，提高可靠性。
4. 分区分配策略
- 策略选择：合理的分区分配策略可以影响消息的可靠性。例如
RangeAssignor策略按范围分配分区，RoundRobinAssignor策略按轮询方式分配分区。选择合适的策略能确保消息在各个分区上分布均匀，避免某些分区负载过高而导致消息发送失败。 - 粘性分区：Kafka 从 2.4 版本开始支持粘性分区策略。该策略在分区分配时，会尽量将生产者与之前分配到的分区保持一致，减少不必要的分区重新分配，提高消息发送的稳定性和可靠性。
5. 缓冲区与批量发送
- 缓冲区参数：
batch.size参数指定了生产者批量发送消息时，缓冲区的大小。当缓冲区达到该大小时，生产者会将缓冲区中的消息批量发送。合理设置batch.size可以提高发送效率，同时减少网络请求次数，从而提高可靠性。 - linger.ms 参数：
linger.ms参数指定了生产者在缓冲区未满时，等待更多消息到达以凑够批量大小的最长时间。设置适当的linger.ms可以增加批量发送的机会，但如果设置过大，可能会导致消息发送延迟增加。