From 0b6cef9c5338891695c7cb1e067217e4b0f72de3 Mon Sep 17 00:00:00 2001 From: Jonas Koch Date: Tue, 19 May 2026 11:54:43 +0200 Subject: [PATCH] handle default values --- msa/js-executor/queue/kafkaTemplate.ts | 2 +- msa/js-executor/queue/oAuthBearerProvider.ts | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) 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;