Publisher messageTypeField can be undefined

Author: CarlosGamero

packages/kafka/lib/AbstractKafkaPublisher.ts

@@ -47,7 +47,6 @@ export abstract class AbstractKafkaPublisher<
     for (const { topic, schemas } of this.topicsConfig) {
       this.schemaContainers[topic] = new MessageSchemaContainer({
         messageSchemas: schemas,
-        messageDefinitions: [],
         messageTypeField: this.options.messageTypeField,
       })
     }

packages/kafka/lib/AbstractKafkaService.ts

@@ -21,7 +21,7 @@ import type {
 
 export type BaseKafkaOptions = {
   kafka: KafkaConfig
-  messageTypeField: string
+  messageTypeField?: string
   messageIdField?: string
   handlerSpy?: HandlerSpy<object> | HandlerSpyParams | boolean
   logMessages?: boolean
@@ -59,14 +59,14 @@ export abstract class AbstractKafkaService<
   protected resolveMessageType(
     message: SupportedMessageValues<TopicsConfig> | null | undefined,
   ): string | undefined {
-    // @ts-expect-error
+    if (!this.options.messageTypeField || !message) return undefined
     return message[this.options.messageTypeField]
   }
 
   protected resolveMessageId(
     message: SupportedMessageValues<TopicsConfig> | null | undefined,
   ): string | undefined {
-    // @ts-expect-error
+    if (!this.options.messageIdField || !message) return undefined
     return message[this.options.messageIdField]
   }