3.2.4 Exactly Once语义 对于某些比较重要的消息,我们需要保证exactly once语义,即保证每条消息被发送且仅被发送一次。 在0.11版本之后,Kafka引入了幂等性机制(idempotent),配合acks = -1时的at least once语义,实现了producer到broker的exactly once语义。 idempotent + at least once = exactly once 使用时,只需将enable.idempotence属性设置为true,kafka自动将acks属性设为-1。