Как правильно вставлять записи в тему aws msk через производителя Java 8?

Question

Я установил новый кластер aws msk с тремя узлами. При создании событий отображается следующая ошибка:

Ошибка при отправке записи java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.TimeoutException: не удалось обновить метаданные после 60000 мс.

Перед тестированием на aws я установил сервер Apache kafka на своей локальной машине. Создал тему и успешно смог создавать и потреблять сообщения из темы.

public class ProducerCreator {
    public static Producer<Long, String> createProducer() {
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, IKafkaConstants.KAFKA_BROKERS);
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, LongSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        return new KafkaProducer<>(props);
    }
}

В приведенном выше коде,

1. kafka_brokers - серверы открытого текста