Мне нужно автоматически масштабировать экземпляр AWS (экземпляр kubernates) на основе очереди kafka, через которую я публикую сообщения.