Need an exception on network failure. [Mandatory, because how else would you know?]

[aniketd]

Producer continues to publish and Consumer's loop is stuck silently on failure of network connection to broker.

How should a client application be notified that the connection is broken?

A connection exception?