Как обеспечить exactly-once семантику в Kafka?