Implementation of only-once guarantee on the producer side https://cwiki.apache.org/confluence/display/KAFKA/Idempotent+Producer