我们暂且不考虑写磁盘的具体过程，先大致看看下面的图，这代表了 Kafka 的核心架构原理。 Kafka 分布式存储架构 那么现在问题来了，如果每天产生几十 TB 的数据，难道都写一台 ...

https://www.cnblogs.com/756623607-zhang/p/10506909.html ...

先处理消费端的丢失数据和重复消费 这俩种情况都是 消息偏移offset的问题导致的，只是场景不同。 offset位移提交一般有俩种方式，自动位移提交和手动位移提交。用enable.auto.commit这个配置属性去控制 丢失消息一般是自动提交的问题，所以切换成手动位移提交就可以 ...

（同步）存活保证数据安全 3）从消费端：关闭自动提交，使用手动提交。 数据不重复消费 1）生产端 ...

Rocketmq如何保证消息不丢失，如何保证消息不被重复消费_meser88的博客-CSDN博客 ...

Kafka作为当下流行的高并发消息中间件，大量用于数据采集，实时处理等场景，我们在享受他的高并发，高可靠时，还是不得不面对可能存在的问题，最常见的就是丢包，重发问题。 1、丢包问题：消息推送服务，每天早上，手机上各终端都会给用户推送消息，这时候流量剧增，可能会出现kafka发送数据过快，导致 ...

Kafka重复消费原因 底层根本原因：已经消费了数据，但是offset没提交。 原因1：强行kill线程，导致消费后的数据，offset没有提交。 原因2：设置offset为自动提交，关闭kafka时，如果在close之前，调用 consumer.unsubscribe ...

一般我们在用到这种消息中件的时候，肯定会考虑要怎样才能保证数据不丢失，在面试中也会问到相关的问题。但凡遇到这种问题，是指3个方面的数据不丢失，即：producer consumer 端数据不丢失 broker端数据不丢失下面我们分别从这三个方面来学习，kafka是如何保证数据不丢失 ...