[Dúvida] erro na conexão com o comsumidor

Olá, Adriano!

Pela imagem que você compartilhou, parece que o consumidor do Kafka está tentando se conectar a um broker no endereço localhost:9092, mas não está conseguindo estabelecer a conexão. Isso pode ser um indicativo de que o broker do Kafka não está rodando ou não está acessível nesse endereço e porta especificados.

Aqui estão algumas etapas que você pode seguir para tentar resolver o problema:

1. Verifique se o Kafka está rodando: Certifique-se de que o Kafka está de fato rodando em sua máquina local. Você pode verificar isso usando ferramentas como o jps (Java Virtual Machine Process Status Tool) para listar processos Java ou verificando os logs do Kafka.

2. Confira o endereço e a porta: Assegure-se de que o endereço e a porta configurados no seu consumidor correspondem aos do broker do Kafka. Se você estiver rodando um cluster Kafka, certifique-se de que está tentando se conectar ao broker correto.

3. Verifique as configurações de rede: Se o Kafka estiver rodando em um container Docker, em uma VM ou em um ambiente de nuvem, verifique se as configurações de rede permitem conexões na porta 9092.

4. Firewall e Antivírus: Confira se o firewall ou o antivírus não estão bloqueando a conexão com a porta 9092.

5. Logs do Kafka: Verifique os logs do Kafka para quaisquer mensagens de erro que possam fornecer mais informações sobre o problema.

6. Configuração do Consumidor: Revise as configurações do consumidor no seu aplicativo Spring para garantir que estão corretas.

Se após seguir essas etapas o problema persistir, você pode precisar de uma investigação mais detalhada sobre a configuração do seu ambiente e do Kafka.

Espero ter ajudado e bons estudos!

Olá Adriano.

O spring boot somente se conecta com o broker do Apache kafka, ele não executa para nós. Sendo assim, é necessário ter o broker executando local, ou seja, o zookeeper e o servidor do kafka executando por um lado e a aplicação spring-boot por outro.

Podes executar diretamente por linha de comando.

1 - executar Zookeeper

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

2 - Executar Kafka

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

Ou se preferes por docker. O kafka podes fazer o download aqui https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz

Obrigado!!