所以我一直在阅读关于卡夫卡的一次语义,我对它的工作原理有点困惑。
我理解生产者如何避免发送重复消息(以防来自代理的确认失败),但我不明白的是,在消费者处理消息但在提交偏移量之前崩溃的情况下,exactly-once 是如何工作的。在这种情况下kafka不会重试吗?
apache-kafka
apache-kafka ×1