kafka的消息发送的三种模式_kafka几种消息模式

作者：空白诗007 | 2024-07-17 10:11:10

踩

kafka几种消息模式

1. At most once模式消费者读取消息，更新消息的offset，然后处理消息。这种方式的风险是在更新消息的offset之后，处理消息结果的输出之前消费者挂掉，消费者再启动的时候，从新的offset开始消费消息，导致处理消息丢失

2. At least once模式消费者读取消息，处理消息并输出，更新消息的offset。这种方式的风险是在处理消息的结果输出之后，更新消息的offset之前消费者挂掉，消费者再启动的时候，会重复消费消息

3. Exactly once模式消费者读取消息，处理消息并输出，同时更新消息的offset。通过将消息的offset和消费者的输出结果放到一起，来保证同时更新消息的offset和消息的处理结果输出，在这种方式下，消息的offset保存在consumer.

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/空白诗007/article/detail/839360