Ainda não tem acesso? Estude com a gente! Matricule-se
Ainda não tem acesso? Estude com a gente! Matricule-se

Solucionado (ver solução)

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!