If **consumer_timeout_ms < session_timeout_ms** then session lasts forever _**even when server is down**_. So there is no chance to catch StopIteration exception to handle out of new messages while handling connection timeout to reconnect on error.