Какой из следующих механизмов обеспечивает наилучшую **гарантию доставки** в Kafka Streams при использовании **stateful processing**?