kafka通过幂等性(Idempotence)和事务(Transaction)实现消息精确一次(exactly once)的可靠性保障。
幂等性 Producer设置props.put(“enable.idempotence”, ture)
2021-03-23