Olá pessoal, estou com um erro ao publicar a mensagem pelo GO
Parece ser por causa do host.docker.internal:172.17.0.1

producer := kafka.NewKafkaProducer() kafka.Publish("olá", "readtest", producer)

Adicionei a linha
127.0.0.1 host.docker.internal no meu etc/hosts mas está dando timeout.
@wesleywillians @argentinaluiz

%3|1655827555.464|FAIL|rdkafka#producer-1| [thrd:host.docker.internal:9094/bootstrap]: host.docker.internal:9094/bootstrap: Connect to ipv4#172.17.0.1:9094 failed: Connection timed out (after 130166ms in state CONNECT)

Boa notie pessoal.
Pois bem, consigo produzir e consumir do broker (kafka) pela aplicação GO, no entanto, ao tentar "subir" o nestjs minha conexão ao broker é recusada conforme print:

ps. Sim, já adicionei o host do broker no arquivo hosts

O mais interessante que eu consigo consumir e produzir normalmente pela app GO.
Utilizo windows 11 com wsl2, alguém com esse problema especifico ?

Boa tarde,

Estou tentando subir o compose do kafka e sistematicamente tenho o mesmo erro:

Eu fiz a configuracao do etc/hosts como requisitado (Add 127.0.0.1 host.docker.internal)

Algo relacionado com o:
extra_hosts:
- 'host.docker.internal:172.17.0.1'?

No lugar de usar a network do meu host, posso criar uma network e usar ela em todos os meus docker-composes?

Valeu!

Olá, estou tomando esse erro ao tentar conectar o nest com o Kafka

A config ssl já está comentada, e /etc/hosts está configurado, no entanto não parece resolver o meu problema.

Mesmo baixando a ultima versão do repositório o erro se mantem.

Assim que adicionei a useFactory nas configs do routes.module.ts, recebi o seguinte erro:

`| [Nest] 124 - 06/29/2022, 8:34:25 PM ERROR [ClientKafka] ERROR [BrokerPool] Failed to connect to seed broker, trying another broker from the list: Connection error: connect ECONNREFUSED 172.17.0.1:9094 {"timestamp":"2022-06-29T20:34:25.980Z","logger":"kafkajs","retryCount":5,"retryTime":9204}

app_1 | (node:124) UnhandledPromiseRejectionWarning: KafkaJSNonRetriableError

app_1 | Caused by: KafkaJSConnectionError: Connection error: connect ECONNREFUSED 172.17.0.1:9094

app_1 | at Socket.onError (/home/node/app/node_modules/kafkajs/src/network/connection.js:210:23)

app_1 | at Socket.emit (events.js:210:5)

app_1 | at emitErrorNT (internal/streams/destroy.js:92:8)

app_1 | at emitErrorAndCloseNT (internal/streams/destroy.js:60:3)

app_1 | at processTicksAndRejections (internal/process/task_queues.js:80:21)

app_1 | (node:124) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 2)

app_1 | (node:124) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.`

Meu repo do projeto: https://github.com/AndreCosta101/nest-api

[ServerKafka] ERROR [Connection] Connection error: Client network socket disconnected before secure TLS connection was established {"timestamp":"2022-06-23T16:52:04.146Z","logger":"kafkajs","broker":"host.docker.internal:9094","clientId":"code-delivery-server","stack":"Error: Client network socket disconnected before secure TLS connection was established\n at connResetException (internal/errors.js:570:14)\n at TLSSocket.onConnectEnd (_tls_wrap.js:1361:19)\n at Object.onceWrapper (events.js:299:28)\n at TLSSocket.emit (events.js:215:7)\n at endReadableNT (_stream_readable.js:1184:12)\n at processTicksAndRejections (internal/process/task_queues.js:80:21)"} +26ms

Bom dia!
Criei os arquivos Dockerfile, docker-compose e também o arquivo entrypoint na pasta .docker, porém ao executar o comando "docker-compose up", estou tendo o seguinte erro:

Tentei até fazer o build através do comando "docker-compose up -d --build", porém tive essa mensagem:

Alguém com erro parecido que possa dar uma ajuda?
Valeu, pessoal!