I'm new to Spring Cloud Stream and curious about how to detect Kafka disconnections in our application for both producing and consuming scenarios.

I tried defining an error handler in the yml files and I observed it only detect code level exceptions.