kafka.admin.service.ts [line: 64]
to reproduce error
`
async onModuleInit(): Promise {
await this.connect();
await this.helperService.delay(5000);
try {
await this.createTopics();
}catch (e) {
console.log(e);
}
await this.helperService.delay(5000);
}
`
KafkaJSNonRetriableError
Caused by: KafkaJSConnectionError: Connection error: getaddrinfo ENOTFOUND kafka
at Socket.onError (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/network/connection.js:210:23)
... 3 lines matching cause stack trace ...
at processTicksAndRejections (node:internal/process/task_queues:82:21) {
name: 'KafkaJSNumberOfRetriesExceeded',
retriable: false,
helpUrl: undefined,
retryCount: 5,
retryTime: 8156,
[cause]: KafkaJSConnectionError: Connection error: getaddrinfo ENOTFOUND kafka
at Socket.onError (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/network/connection.js:210:23)
at Socket.emit (node:events:513:28)
at emitErrorNT (node:internal/streams/destroy:151:8)
at emitErrorCloseNT (node:internal/streams/destroy:116:3)
at processTicksAndRejections (node:internal/process/task_queues:82:21) {
retriable: true,
helpUrl: undefined,
broker: 'kafka:9092',
code: 'ENOTFOUND',
[cause]: undefined
}
}
[Nest] 8102 - 07/29/2022, 1:03:33 AM ERROR [ClientKafka] ERROR [Connection] Response Metadata(key: 3, version: 6) {"timestamp":"2022-07-28T18:03:33.511Z","logger":"kafkajs","broker":"localhost:9092","clientId":"KAFKA_ACK-client","error":"This server does not host this topic-partition","correlationId":1,"size":125}
/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/protocol/error.js:581
return new KafkaJSProtocolError(errorCodes.find(e => e.code === code) || unknownErrorCode(code))
^
KafkaJSProtocolError: This server does not host this topic-partition
at createErrorFromCode (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/protocol/error.js:581:10)
at Object.parse (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/protocol/requests/metadata/v0/response.js:55:11)
at Connection.send (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/network/connection.js:433:35)
at processTicksAndRejections (node:internal/process/task_queues:95:5)
at Broker.[private:Broker:sendRequest] (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/broker/index.js:875:14)
at Broker.metadata (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/broker/index.js:177:12)
at /Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/cluster/brokerPool.js:158:25
at /Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/cluster/index.js:111:14
at Cluster.refreshMetadata (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/cluster/index.js:172:5)
at Cluster.addMultipleTargetTopics (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/cluster/index.js:230:11)
at Object.subscribe (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/kafkajs/src/consumer/index.js:185:5)
at async Promise.all (index 0)
at ClientKafka.bindTopics (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/@nestjs/microservices/client/client-kafka.js:84:9)
at ClientKafka.connect (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/node_modules/@nestjs/microservices/client/client-kafka.js:72:13)
at KafkaProducerService.onApplicationBootstrap (/Users/shahanul/WebstormProjects/ack-microservice-nestjs-boilerplate-mongoose/src/kafka/producer/service/kafka.producer.service.ts:42:9)
at async Promise.all (index 0)
error Command failed with exit code 1.
16 Dec 13, 2022
7 Nov 21, 2022
10 Aug 15, 2022
3 Sep 19, 2022
36 Dec 26, 2022
21 Nov 15, 2022
2.5k Dec 26, 2022
34k Dec 28, 2022
21.7k Jan 1, 2023
9.8k Jan 3, 2023
3k Dec 30, 2022
268 Dec 27, 2022
2 Sep 21, 2021
1 Jul 6, 2022
2 Jul 21, 2022
3 Sep 21, 2022
4 Dec 15, 2022
2 Jun 6, 2022
2 Feb 17, 2022