Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a test