kafka提供了at-least-once 至少一次的语义保证。多余的消息可能由于生产者重试, 消费者失败重启等原因造成的。kakf-client 在0.11.0.0版本加入了对事务的支持提供了exactly-once的语义.
at-least-once
0.11.0.0
exactly-once
← kafka 学习系列 04-spring boot 集成 spring-kafka vim的使用→