Какие стратегии вы применяете для **обнаружения и восстановления после сбоев** в стрим-процессинге, особенно при использовании Kafka Streams или Flink? Какие метрики и инструменты вы используете для мониторинга?