diff --git a/msa/js-executor/queue/kafkaTemplate.ts b/msa/js-executor/queue/kafkaTemplate.ts
index 3be36a8061..30a53304d3 100644
--- a/msa/js-executor/queue/kafkaTemplate.ts
+++ b/msa/js-executor/queue/kafkaTemplate.ts
@@ -98,7 +98,7 @@ export class KafkaTemplate implements IQueue {
                     clientId: config.get('kafka.confluent.oauth.client_id'),
                     clientSecret: config.get('kafka.confluent.oauth.client_secret'),
                     host:  config.get('kafka.confluent.oauth.endpoint_url'),
-                    refreshThresholdMs: config.get('kafka.confluent.oauth.refresh_threshold'),
+                    refreshThresholdMs: config.has('kafka.confluent.oauth.refresh_threshold')?config.get('kafka.confluent.oauth.refresh_threshold'):60000,
                 })
                 };
             }
diff --git a/msa/js-executor/queue/oAuthBearerProvider.ts b/msa/js-executor/queue/oAuthBearerProvider.ts
index f09c5b2e51..08323d2046 100644
--- a/msa/js-executor/queue/oAuthBearerProvider.ts
+++ b/msa/js-executor/queue/oAuthBearerProvider.ts
@@ -15,7 +15,8 @@
 ///
 
 import { AccessToken, ClientCredentials } from 'simple-oauth2'
-import { _logger, KafkaJsWinstonLogCreator } from '../config/logger';
+import { _logger } from '../config/logger';
+import { error } from 'winston';
 
 interface OauthBearerProviderOptions {
   clientId: string;