Ошибка подключения к брокеру Kafka при публикации сообщения через Java-приложение ⇐ JAVA

[Anonymous]

Я пытаюсь опубликовать сообщение Kafka, запуская Java-приложение (на моем ноутбуке с Windows) на брокере Kafka, работающем на Ubuntu (на моем ноутбуке с Windows). Я получаю следующую ошибку:

Код: Выделить всё

    [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Node -1 disconnected.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected

Вот код Java:
public static void main(String[] args) {

Код: Выделить всё

        //create producer properties
Properties properties = new Properties();

//connect to localhost
properties.setProperty("bootstrap.servers", "127.0.0.1:9092");

//set producer properties
properties.setProperty("key.serializer", StringSerializer.class.getName());
properties.setProperty("value.serializer", StringSerializer.class.getName());

//create the producer
KafkaProducer producer = new KafkaProducer(properties);
//create a Producer Record
ProducerRecord producerRecord = new ProducerRecord("demo_java", "hello world");

//send data
producer.send(producerRecord);

//tell the producer to send all data and block until done -- synchronous
producer.flush();

//flush and close the producer
producer.close();
}

Что я пробовал:

• Создал правило брандмауэра для входящего трафика, открывающее порт 9092.
• успешно выполнил команду telnet localhost 9092 на моем ноутбуке с Windows и Ubuntu

Выполнил любую команду kafka (например, kafka- темы.sh --bootstrap-server localhost:9092 --topic --list) успешно работает на сервере Ubuntu. Я установил Ubuntu на свой ноутбук с Windows.

Подробнее здесь: https://stackoverflow.com/questions/793 ... h-java-app