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.