第六十四天

自己实现过哪些数据结构?

自己回答 参考：https://www.topgoer.cn/docs/data-structures-questions/data-structures-questions-1d94smov8irdb

kafka挂了, 如何保证异步消息不丢失?

为了保证Kafka在出现故障时异步消息不丢失，可以采取以下措施：

1. 设置合适的acks：在Producer端设置acks=all，这样可以确保消息被所有副本接收后才认为发送成功。这增加了消息持久性，但可能会降低一些性能。
2. 启用副本机制：确保每个分区有多个副本，这样即使Leader副本发生故障，Follower副本也可以继续服务，避免数据丢失。
3. 监控和报警：建立监控系统来监控Kafka的运行状态，包括消息量、延迟、系统负载等关键指标。一旦发现异常，立即进行报警，以便及时响应和处理。
4. 备份和恢复策略：定期备份Kafka的数据，并确保有有效的灾难恢复计划，以便在系统崩溃时能够迅速恢复数据。
5. 使用事务：Kafka支持事务，可以在需要高一致性保证的场景下使用事务来确保消息的准确传递。
6. 消费者确认：消费者在消费消息后，可以通过提交offset来确认消息已被正确处理。如果消费者在处理消息前保存了offset，那么即使发生故障，也可以通过offset来恢复数据。
7. 合理配置生产者重试：生产者在发送失败时会进行重试，可以通过配置重试次数和重试间隔来平衡性能和可靠性。
8. 日志段文件的保留策略：通过设置日志段文件的保留时间，可以防止因日志文件过早删除而导致的潜在数据丢失。
9. 定期检查和测试：定期对Kafka集群进行检查和压力测试，确保集群健康并且能够在高负载下稳定运行。