fix: JOIN-32570 validate when additional fields are passed

join-com · Jun 16, 2023 · 5399af4 · 5399af4
1 parent 40dcae4
commit 5399af4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/pubsub/src/Publisher.ts b/packages/pubsub/src/Publisher.ts
@@ -86,7 +86,7 @@ export class Publisher<T = unknown> {
 
   private logWarnIfMessageViolatesSchema(data: T): void {
     if (this.writerAvroType) {
-      if (!this.writerAvroType.isValid(data)) {
+      if (!this.writerAvroType.isValid(data, {noUndeclaredFields: true})) {
         this.logger?.warn(`[schema-violation] [${this.topicName}] Message violates writer avro schema`, { payload: data, metadata: this.avroMessageMetadata })
       }
     }