TypeError: Cannot read property 'host' of undefined
jason51553262 opened this issue · 0 comments
jason51553262 commented
I'm getting TypeError: Cannot read property 'host' of undefined exception when kafka host is reachable but KAFKA_ADVERTISED_LISTENERS is misconfigured, so kafka is not reachable.
Bug Report
Environment
- Node version: v14.16.1
- Kafka-node version: 5.0.0
- Kafka version: 2.7.0
For specific cases also provide
- Number of Brokers: 1
- Number partitions for topic: 1
Include Sample Code to reproduce behavior
const kafka = require('kafka-node');
const util = require('util');
const PARTITIONS = 1;
const REPLICATION_FACTOR = 1;
const Client = kafka.KafkaClient;
const createTopic = async (url, topic) => {
return new Promise((resolve, reject) => {
try {
const clientConfig = { // https://github.com/SOHU-Co/kafka-node#kafkaclient
kafkaHost: url,
requestTimeout: 5000,
connectTimeout: 5000,
connectRetryOptions: { // https://www.npmjs.com/package/retry
forever: true,
},
};
const client = new Client(clientConfig);
const topicsToCreate = [{
topic: topic,
partitions: PARTITIONS,
replicationFactor: REPLICATION_FACTOR,
}];
client.createTopics(topicsToCreate, (error, result) => {
if (error) {
reject(error);
}
else {
if (result[0] && result[0].error) {
if (result[0].error.endsWith('already exists.')) {
// no worries, carry on
console.log(util.format('Topic \'%s\' already exists', topic));
resolve();
}
else {
reject(result[0].error);
}
}
else {
resolve();
}
}
});
}
catch (error) {
reject(error);
}
});
};
const main = async () => {
try {
await createTopic('kafka1:9092', 'testing123');
}
catch (error) {
console.error('error:', error);
}
};
main();
Include output with Debug turned on
/Users/jason/.nvm/versions/node/v14.17.1/bin/node /Users/jason/plcode/common-libs/common-libs-pubsub/test.js
kafka-node:KafkaClient Connect attempt 1 +0ms
kafka-node:KafkaClient Trying to connect to host: kafka1 port: 9092 +2ms
kafka-node:KafkaClient kafka-node-client createBroker kafka1:9092 +1ms
kafka-node:KafkaClient missing apiSupport waiting until broker is ready...(loadMetadataForTopics) +10ms
kafka-node:KafkaClient waitUntilReady [BrokerWrapper kafka1:9092 (connected: true) (ready: false) (idle: false) (needAuthentication: false) (authenticated: false)] +0ms
kafka-node:KafkaClient kafka-node-client sending versions request to kafka1:9092 +7ms
kafka-node:KafkaClient broker socket connected {"host":"kafka1","port":9092} +2ms
kafka-node:KafkaClient connected to socket, trying to load initial metadata +0ms
kafka-node:KafkaClient missing apiSupport waiting until broker is ready...(loadMetadataForTopics) +1ms
kafka-node:KafkaClient waitUntilReady [BrokerWrapper kafka1:9092 (connected: true) (ready: false) (idle: false) (needAuthentication: false) (authenticated: false)] +0ms
kafka-node:KafkaClient Received versions response from kafka1:9092 +3ms
kafka-node:KafkaClient setting api support to {"21":{"min":0,"max":2,"usable":false},"22":{"min":0,"max":3,"usable":false},"23":{"min":0,"max":3,"usable":false},"24":{"min":0,"max":1,"usable":false},"25":{"min":0,"max":1,"usable":false},"26":{"min":0,"max":1,"usable":false},"27":{"min":0,"max":0,"usable":false},"28":{"min":0,"max":3,"usable":false},"29":{"min":0,"max":2,"usable":false},"30":{"min":0,"max":2,"usable":false},"31":{"min":0,"max":2,"usable":false},"33":{"min":0,"max":1,"usable":false},"34":{"min":0,"max":1,"usable":false},"35":{"min":0,"max":2,"usable":false},"37":{"min":0,"max":2,"usable":false},"38":{"min":0,"max":2,"usable":false},"39":{"min":0,"max":2,"usable":false},"40":{"min":0,"max":2,"usable":false},"41":{"min":0,"max":2,"usable":false},"42":{"min":0,"max":2,"usable":false},"43":{"min":0,"max":2,"usable":false},"44":{"min":0,"max":1,"usable":false},"45":{"min":0,"max":0,"usable":false},"46":{"min":0,"max":0,"usable":false},"47":{"min":0,"max":0,"usable":false},"48":{"min":0,"max":0,"usable":false},"49":{"min":0,"max":0,"usable":false},"produce":{"min":0,"max":8,"usable":2},"fetch":{"min":0,"max":11,"usable":2},"offset":{"min":0,"max":5,"usable":0},"metadata":{"min":0,"max":9,"usable":1},"leader":{"min":0,"max":4,"usable":false},"stopReplica":{"min":0,"max":3,"usable":false},"updateMetadata":{"min":0,"max":6,"usable":false},"controlledShutdown":{"min":0,"max":3,"usable":false},"offsetCommit":{"min":0,"max":8,"usable":2},"offsetFetch":{"min":0,"max":7,"usable":1},"groupCoordinator":{"min":0,"max":3,"usable":0},"joinGroup":{"min":0,"max":7,"usable":0},"heartbeat":{"min":0,"max":4,"usable":0},"leaveGroup":{"min":0,"max":4,"usable":0},"syncGroup":{"min":0,"max":5,"usable":0},"describeGroups":{"min":0,"max":5,"usable":0},"listGroups":{"min":0,"max":4,"usable":0},"saslHandshake":{"min":0,"max":1,"usable":1},"apiVersions":{"min":0,"max":3,"usable":0},"createTopics":{"min":0,"max":5,"usable":1},"deleteTopics":{"min":0,"max":4,"usable":false},"describeConfigs":{"min":0,"max":3,"usable":2},"saslAuthenticate":{"min":0,"max":2,"usable":0}} +0ms
kafka-node:KafkaClient broker is now ready +0ms
kafka-node:KafkaClient broker is now ready +1ms
kafka-node:KafkaClient kafka-node-client updated internal metadata +2ms
/Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/lib/kafkaClient.js:282
var broker = this.getBroker(controllerMetadata.host, controllerMetadata.port);
^
TypeError: Cannot read property 'host' of undefined
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/lib/kafkaClient.js:282:52
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/lib/kafkaClient.js:919:7
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:3888:9
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:473:16
at replenish (/Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:1006:25)
at iterateeCallback (/Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:995:17)
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:969:16
at /Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/node_modules/async/dist/async.js:3885:13
at KafkaClient.wrappedFn (/Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/lib/kafkaClient.js:481:14)
at KafkaClient.Client.invokeResponseCallback (/Users/jason/plcode/common-libs/common-libs-pubsub/node_modules/kafka-node/lib/baseClient.js:593:10)