1
resposta

[Reclamação] AO RODAR FraudDetectorService - não conecta no (/127.0.0.1:9092)

Parece que não está conseguindo conectar no IP /127.0.0.1:9092

RODOU NORMAL - bin/zookeeper-server-start.sh config/zookeeper.properties

LOG - [2025-05-25 12:14:19,565] INFO PrepRequestProcessor (sid:0) started, reconfigEnabled=false (org.apache.zookeeper.server.PrepRequestProcessor) [2025-05-25 12:14:19,585] INFO Using checkIntervalMs=60000 maxPerMinute=10000 maxNeverUsedIntervalMs=0 (org.apache.zookeeper.server.ContainerManager) [2025-05-25 12:14:38,984] INFO Creating new log file: log.1f (org.apache.zookeeper.server.persistence.FileTxnLog)

RODOU NORMAL

bin/kafka-server-start.sh config/server.properties

LOG - [2025-05-25 12:14:40,585] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Started socket server acceptors and processors (kafka.network.SocketServer) [2025-05-25 12:14:40,594] INFO Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser) [2025-05-25 12:14:40,594] INFO Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser) [2025-05-25 12:14:40,594] INFO Kafka startTimeMs: 1748186080585 (org.apache.kafka.common.utils.AppInfoParser) [2025-05-25 12:14:40,596] INFO [KafkaServer id=0] started (kafka.server.KafkaServer) [2025-05-25 12:14:40,662] INFO [BrokerToControllerChannelManager broker=0 name=alterIsr]: Recorded new controller, from now on will use broker boldox.:9092 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread) [2025-05-25 12:14:40,713] INFO [BrokerToControllerChannelManager broker=0 name=forwarding]: Recorded new controller, from now on will use broker boldox.:9092 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread)

ERRO AO RODAR A CLASSE **FraudDetectorService **

main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.3.1 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 18a913733fb71c01 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1748268919379 [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Subscribed to topic(s): ECOMMERCE_NEW_ORDER [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=dd685eea-25a9-4c51-af53-60435eef0467, groupId=FraudDetectorService] Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available. .

1 resposta

Oi Juliano! Como vai?

Valide se o Kafka Broker está realmente rodando no endereço 127.0.0.1:9092. Você pode testar isso usando a ferramenta kafka-topics.sh para listar os tópicos disponíveis e verificar se consegue se conectar ao broker.

bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092

Se você não conseguir listar os tópicos, pode ser que o broker não esteja rodando corretamente ou que a porta esteja incorreta. Além disso, verifique se há alguma configuração de firewall ou de rede que possa estar bloqueando a conexão na porta 9092.

Por fim, às vezes, reiniciar o Zookeeper e o Kafka pode resolver problemas de conexão, especialmente após alterações na configuração.

Espero que uma dessas dicas ajude a resolver o problema de conexão.

Bons estudos!

Caso este post tenha lhe ajudado, por favor, marcar como solucionado ✓.