Какой из следующих механизмов обеспечивает **idempotent consumer** в Kafka?