File tree Expand file tree Collapse file tree 4 files changed +3
-7
lines changed Expand file tree Collapse file tree 4 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -103,7 +103,7 @@ chronos.track = () => {
103
103
return null ;
104
104
} ;
105
105
106
- /**
106
+ /**
107
107
* **********************************************
108
108
* COLLECT KAFKA METRICS
109
109
* Only supports MongoDB and PostgreSQL for now!
@@ -112,7 +112,7 @@ chronos.track = () => {
112
112
113
113
chronos . kafka = function ( ) {
114
114
const { database, jmxuri } = userConfig ;
115
- if ( jmxuri === undefined ) {
115
+ if ( jmxuri === undefined ) {
116
116
console . log ( 'No specified URI for a JMX Exporter' ) ;
117
117
return ;
118
118
}
Original file line number Diff line number Diff line change @@ -156,8 +156,6 @@ healthHelpers.collectHealthData = () => {
156
156
} )
157
157
) ;
158
158
159
-
160
-
161
159
promises . push (
162
160
si
163
161
. processes ( )
Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ kafkaHelpers.kafkaFetch = function (config) {
42
42
return fetch ( config . jmxuri )
43
43
. then ( data => data . text ( ) )
44
44
. then ( data => kafkaHelpers . extractWord ( data ) )
45
- . catch ( err => console . log ( err ) ) ;
45
+ . catch ( err => console . log ( 'Error Fetching Data from JMX Exporter: ' , err ) ) ;
46
46
} ;
47
47
48
48
module . exports = kafkaHelpers ;
Original file line number Diff line number Diff line change @@ -320,8 +320,6 @@ chronos.kafka = function (userConfig) {
320
320
const numDataPoints = parsedArray . length ;
321
321
const queryString = createQueryString ( numDataPoints , 'kafkametrics' ) ;
322
322
const queryArray = createQueryArray ( parsedArray ) ;
323
- // console.log('POSTGRES QUERY STRING: ', queryString);
324
- // console.log('POSTGRES QUERY ARRAY', queryArray);
325
323
return client . query ( queryString , queryArray ) ;
326
324
} )
327
325
. then ( ( ) => console . log ( 'Kafka metrics recorded in PostgreSQL' ) )
You can’t perform that action at this time.
0 commit comments