[streaming] Kafka fault tolerance