Невозможно создать сообщение Kafka для темы, существующей в экземпляре AWS - PullRequest
Новая
       5

Невозможно создать сообщение Kafka для темы, существующей в экземпляре AWS

0 голосов
/ 26 января 2019

Я пытаюсь отправить сообщение в тему Кафки. Тема создана на экземпляре AWS EC2. Когда я отправляю сообщение в тему со своей машины (localhost), ничего не происходит. Однако, когда я попытался выдвинуть его вручную из экземпляра EC2, он работал нормально. Также я удостоверяюсь, что мой экземпляр разрешает весь входящий / исходящий трафик.

файл server.properties 

    zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=1000000
# public IP for the instance
advertised.listeners=PLAINTEXT://18.222.151.131:9092 
# private IP for the instance
listeners=PLAINTEXT://172.31.43.18:9092

И ниже мой производитель Java-код 

public static void run() throws InterruptedException {
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "18.222.151.131:9092");
        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer kafkaProducer = new KafkaProducer(properties);
        kafkaProducer.send(new ProducerRecord(topic, "Hello AWS"));
        producer.close();
        }
...