File tree Expand file tree Collapse file tree 1 file changed +5
-7
lines changed
services/apps/cron_service/src/jobs Expand file tree Collapse file tree 1 file changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -28,17 +28,15 @@ const job: IJobDefinition = {
2828 let msg = ``
2929
3030 for ( const [ topic , groups ] of map ) {
31- if ( toIgnore . includes ( topic . trim ( ) ) ) {
32- ctx . log . info ( `Ignoring topic ${ topic } !` )
33- continue
34- }
35-
3631 const totalMessages = await getTopicMessageCount ( ctx . log , admin , topic )
3732 telemetry . gauge ( `kafka.${ topic } .total` , totalMessages )
3833
3934 if ( groups . length === 0 ) {
40- msg += `No consumer groups found for topic ${ topic } ! Total messages in topic: ${ totalMessages } \n`
41- continue
35+ if ( toIgnore . includes ( topic . trim ( ) ) ) {
36+ ctx . log . info ( `Ignoring topic ${ topic } !` )
37+ } else {
38+ msg += `No consumer groups found for topic ${ topic } ! Total messages in topic: ${ totalMessages } \n`
39+ }
4240 }
4341
4442 for ( const group of groups ) {
You can’t perform that action at this time.
0 commit comments