Solucionado (ver solução)
Solucionado
(ver solução)
1
resposta

Producer não posta mensagem no tópico

Estou com dificuldades para rodar o código do Producer. Fiz todas as etapas da aula e conferi o código no github, porém nada alterou a mensagem de erro.

O Zookeeper e o Kafka estão ativos e funcionais, pois consigo enviar mensagens por linha de comando.

Parece haver problemas de conexão pelo que indica a mensagem, porém no código, não estou chamando o kafka por: brunohprada.localdomain:9092 e sim por: 192.168.1.102:9092.

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node brunohprada.localdomain:9092 (id: 0 rack: null)
java.net.UnknownHostException: brunohprada.localdomain
    at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:798)
    at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1489)
    at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1348)
    at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1282)
    at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:104)
    at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:403)
    at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:363)
    at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151)
    at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:943)
    at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:288)
    at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:361)
    at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:334)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244)
    at java.base/java.lang.Thread.run(Thread.java:830)```
1 resposta
solução!

Depois de muito tentar resolver as mensagens de erro, acabei por mudar de ambiente de desenvolvimento. Estava trabalhando no Windows com um ubuntu rodando no subsistema, porém isso só atrapalhou. Subi uma VM com Ubuntu e fiz todo o curso por essa VM linux. Não tive mais problemas!