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 6583bbc commit 20024e3Copy full SHA for 20024e3
src/app.js
@@ -76,14 +76,17 @@ function startKafkaConsumer(handlers, notificationServiceHandlers) {
76
});
77
78
const check = function () {
79
+ logger.debug('Checking Health...') ;
80
if (!consumer.client.initialBrokers && !consumer.client.initialBrokers.length) {
81
+ logger.debug('Found unhealthy Kafka Brokers...');
82
return false;
83
}
84
let connected = true;
85
consumer.client.initialBrokers.forEach(conn => {
86
logger.debug(`url ${conn.server()} - connected=${conn.connected}`);
87
connected = conn.connected & connected;
88
89
+ logger.debug('Found all Kafka Brokers healthy...');
90
return connected;
91
};
92
0 commit comments