Невозможно создать тему Kafka, работающую на WSL 2 из Windows. ⇐ JAVA

[Anonymous]

Я успешно запускаю последнюю версию Kafka на Ubuntu WSL2. Я могу запускать Zookeeper, сервер Kafka, создавать темы, создавать и использовать консоль из Ubuntu, которую я запускаю на WSL. Однако, когда я захожу в свой Intellij в Windows и создаю простой Java Producer, похоже, он не может подключиться к брокеру
Версии и имя хоста< /p>
Java version: 1.8
Kafka Version: 2.6
hostname (from Ubuntu): KDAAPPDEV04
hostname (from Powershell): KDAAPPDEV04
java.net.InetAddress.getLocalHost().getHostName() = KDAAPPDEV04
java.net.InetAddress.getLocalHost().getCanonicalHostName() = KDAAPPDEV04
netstat from CMD:
TCP [::1]:9092 [::]:0 LISTENING

server.properties
Я нашел эти настройки в другом ответе SO, но они мне не помогли.
advertised.listeners=PLAINTEXT://127.0.0.1:9092
listener.security.protocol.map=PLAINTEXT:PLAINTEXT
listeners=PLAINTEXT://0.0.0.0:9092

затем попробовал (и перезапустил Zookeeper и Kafka)
advertised.listeners=PLAINTEXT://KDAAPPDEV04:9092
listener.security.protocol.map=PLAINTEXT:PLAINTEXT
listeners=PLAINTEXT://0.0.0.0:9092

Производитель
Я запускаю этого производителя с тремя разными значениями: имя хоста, локальный хост и 127.0.0.1, но он никогда не подключается. брокеру
public class ProducerDemo{

private static Logger logger = LoggerFactory.getLogger(ProducerDemo.class);

public static void main(String[] args) throws UnknownHostException{

System.out.println(InetAddress.getLocalHost().getHostName());
System.out.println(InetAddress.getLocalHost().getCanonicalHostName());

String bootstrapServers = "127.0.0.1:9092";
// String bootstrapServers = "localhost:9092";
// String bootstrapServers = "KDAAPPDEV04:9092";

//create Producer properties
Properties properties = new Properties();
properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapServers);
properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());

//create the producer
KafkaProducer producer = new KafkaProducer(properties);

//create a producer record
ProducerRecord record = new ProducerRecord("first-topic","hola mundo");

//send data
producer.send(record);

//flush + close
producer.flush();
producer.close();
}
}

Ошибка
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.6.0
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 62abe01bee039651
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1601666175706
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Connection to node -1 (KDAAPPDEV04/my-ipconfig-address-here:9092) could not be established. Broker may not be available.


Подробнее здесь: https://stackoverflow.com/questions/641 ... om-windows