Add Connection error handling callback in order to get custom error messages from broker, similar to this pr in GO: https://github.com/memphisdev/memphis.go/pull/116