Какой из следующих подходов наиболее эффективен для обеспечения **fault tolerance** в системе на основе Kafka?