Initial PermissionConsumer + type error fix

Author: CarlosGamero

packages/kafka/lib/AbstractKafkaConsumer.ts

@@ -14,7 +14,10 @@ import type { KafkaHandlerRouting } from './handler-container/KafkaHandlerRoutin
 import type { KafkaDependencies, TopicConfig } from './types.ts'
 
 export type KafkaConsumerOptions<TopicsConfig extends TopicConfig[]> = BaseKafkaOptions &
-  Omit<ConsumerOptions<string, object, string, object>, 'deserializers' | 'autocommit'> &
+  Omit<
+    ConsumerOptions<string, object, string, object>,
+    'deserializers' | 'autocommit' | 'bootstrapBrokers'
+  > &
   Omit<ConsumeOptions<string, object, string, object>, 'topics'> & {
     handlers: KafkaHandlerRouting<TopicsConfig>
   }

packages/kafka/test/consumer/PermissionConsumer.ts

@@ -0,0 +1,33 @@
+import { randomUUID } from 'node:crypto'
+import {
+  AbstractKafkaConsumer,
+  type KafkaConsumerOptions,
+} from '../../lib/AbstractKafkaConsumer.js'
+import { type KafkaDependencies, KafkaHandlerRoutingBuilder } from '../../lib/index.js'
+import type { PERMISSION_TOPIC_MESSAGES_CONFIG } from '../utils/permissionSchemas.js'
+import { getKafkaConfig } from '../utils/testContext.js'
+
+export type PermissionConsumerOptions = Partial<
+  Pick<
+    KafkaConsumerOptions<typeof PERMISSION_TOPIC_MESSAGES_CONFIG>,
+    'kafka' | 'handlerSpy' | 'autocreateTopics'
+  >
+>
+
+export class PermissionConsumer extends AbstractKafkaConsumer<
+  typeof PERMISSION_TOPIC_MESSAGES_CONFIG
+> {
+  constructor(deps: KafkaDependencies, options: PermissionConsumerOptions = {}) {
+    super(deps, {
+      handlers: new KafkaHandlerRoutingBuilder().build(),
+      autocreateTopics: options.autocreateTopics ?? true,
+      clientId: randomUUID(),
+      groupId: randomUUID(),
+      kafka: options.kafka ?? getKafkaConfig(),
+      logMessages: true,
+      handlerSpy: options.handlerSpy ?? true,
+      messageIdField: 'id',
+      messageTypeField: 'type',
+    })
+  }
+}