We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 017f83c commit 75ead2dCopy full SHA for 75ead2d
utils/kafka.js
@@ -66,10 +66,12 @@ class Kafka {
66
// check if there is kafka connection alive
67
check() {
68
if (!this.consumer.client.initialBrokers && !this.consumer.client.initialBrokers.length) {
69
+ logger.info(`Brokers Exist Check Failed ${this.consumer.client.initialBrokers} ${this.consumer.client.initialBrokers.length}`)
70
return false;
71
}
72
let connected = true;
73
this.consumer.client.initialBrokers.forEach((conn) => {
74
+ logger.info(`Brokers Check Failed ${JSON.stringify(conn)}`)
75
connected = conn.connected && connected;
76
});
77
0 commit comments