Каким образом можно осуществить восстановление неисправного источника данных в системе Kafka?