首页 > 项目 > 当前页面

Kafka保证消息不丢失主要从三个方面考虑

2026-07-07 NEW个对象

Kafka保证消息不丢失主要从三个方面考虑。生产者端，通过设置 acks=all，保证消息必须被 ISR 副本确认后才算发送成功，同时开启幂等和重试机制避免网络异常导致消息丢失或重复。Broker端，通过副本机制和 min.insync.replicas 保证即使 Leader 宕机也有副本可以恢复。消费者端，关闭自动提交 offset，业务处理成功后手动提交 offset，避免消息消费失败但是 offset 已提交导致消息丢失。

上一篇： Jenkins+K8s+GitLab+Harbor 高效CI/CD自动化发布系统

下一篇：如果codereview，应该如何落地，如果遇到代码不规范，但是项目又记着上线该如何处理？

相关文章

  • Spring Boot 3.0新特性

    Spring Boot 3.0新特性

    NEW个对象 2024-10-03

  • 工厂模式与抽象工厂模式的区别？

    工厂模式：产品接口，具体的产品，工厂 抽象工厂模式：产品接口，具体的产品，工厂接口，具体的工厂。

    NEW个对象 2025-01-11

  • 分布式锁粒度

    在任务中心里，每个用户的任务进度以JSON的格式存放在数据库表里。 因此redis锁的设置：task:lock:taskId，所有的过滤器都添加锁，因为每个过滤器都会影响任务的进度。

    NEW个对象 2025-02-13

NEW个对象 NEW个对象
JAVA是世界上最好的语言

推荐文章

最新文章