From 09c499d21747e83d71ca4648be277b54e659caed Mon Sep 17 00:00:00 2001 From: Eugene Taran Date: Fri, 15 Dec 2023 17:37:31 +0100 Subject: [PATCH] fix: TECH add more logs --- packages/pubsub/src/Publisher.ts | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/packages/pubsub/src/Publisher.ts b/packages/pubsub/src/Publisher.ts index 5ea954b..3928f1f 100644 --- a/packages/pubsub/src/Publisher.ts +++ b/packages/pubsub/src/Publisher.ts @@ -37,7 +37,14 @@ export class Publisher { private readonly avroMessageMetadata?: Record private readonly fieldsProcessor = new FieldsProcessor() //TODO: remove flags below, when only avro will be used - private topicHasAssignedSchema = false + private privateTopicHasAssignedSchema = false + get topicHasAssignedSchema(): boolean { + return this.privateTopicHasAssignedSchema + } + set topicHasAssignedSchema(value: boolean) { + this.privateTopicHasAssignedSchema = value + this.logger?.info(`topicHasAssignedSchema set to ${JSON.stringify(value)}`) + } private avroSchemasProvided = false constructor(readonly topicName: string, readonly client: PubSub, private readonly logger?: ILogger, @@ -228,7 +235,7 @@ export class Publisher { private async doesTopicHaveSchemaAssigned(): Promise { const [metadata] = await this.topic.getMetadata() - this.logger?.info('receivedMetadata:', JSON.stringify(metadata)) + this.logger?.info('receivedMetadata:', metadata) const schemaName = metadata?.schemaSettings?.schema return !!schemaName }