Make it possible to narrow between message types

tulios · Jun 28, 2022 · e1b016e · e1b016e
1 parent c360613
commit e1b016e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/types/index.d.ts b/types/index.d.ts
@@ -638,6 +638,7 @@ interface MessageSetEntry {
   attributes: number
   offset: string
   size: number
+  headers?: never
 }
 
 interface RecordBatchEntry {
@@ -647,6 +648,7 @@ interface RecordBatchEntry {
   attributes: number
   offset: string
   headers: IHeaders
+  size?: never
 }
 
 export type KafkaMessage = MessageSetEntry | RecordBatchEntry