Fixing type issue (#290)

* Removing duplicate property in consumer options

* Release prepare

Author: CarlosGamero

packages/kafka/lib/AbstractKafkaConsumer.ts

@@ -19,15 +19,15 @@ import { AbstractKafkaService, type BaseKafkaOptions } from './AbstractKafkaServ
 import { KafkaHandlerContainer } from './handler-container/KafkaHandlerContainer.ts'
 import type { KafkaHandlerRouting } from './handler-container/KafkaHandlerRoutingBuilder.ts'
 import type { KafkaHandler, RequestContext } from './handler-container/index.ts'
-import type { KafkaDependencies, TopicConfig } from './types.ts'
+import type { KafkaConfig, KafkaDependencies, TopicConfig } from './types.ts'
 
 export type KafkaConsumerDependencies = KafkaDependencies &
   Pick<QueueConsumerDependencies, 'transactionObservabilityManager'>
 
 export type KafkaConsumerOptions<TopicsConfig extends TopicConfig[]> = BaseKafkaOptions &
   Omit<
     ConsumerOptions<string, object, string, string>,
-    'deserializers' | 'autocommit' | 'bootstrapBrokers'
+    'deserializers' | 'autocommit' | keyof KafkaConfig
   > &
   Omit<ConsumeOptions<string, object, string, string>, 'topics'> & {
     handlers: KafkaHandlerRouting<TopicsConfig>

packages/kafka/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/kafka",
-    "version": "0.1.1",
+    "version": "0.1.2",
     "engines": {
         "node": ">= 22.14.0"
     },

packages/kafka/test/consumer/PermissionConsumer.spec.ts

@@ -80,8 +80,11 @@ describe('PermissionConsumer', () => {
       // Given
       consumer = new PermissionConsumer(testContext.cradle, {
         // port 9090 is not valid
-        kafka: { bootstrapBrokers: ['localhost:9090'], clientId: randomUUID() },
-        connectTimeout: 10, // Short timeout to trigger failure quick
+        kafka: {
+          bootstrapBrokers: ['localhost:9090'],
+          clientId: randomUUID(),
+          connectTimeout: 10, // Short timeout to trigger failure quick
+        },
       })
 
       // When - Then

packages/kafka/test/consumer/PermissionConsumer.ts

@@ -20,12 +20,7 @@ import { getKafkaConfig } from '../utils/testContext.js'
 export type PermissionConsumerOptions = Partial<
   Pick<
     KafkaConsumerOptions<typeof PERMISSION_TOPIC_MESSAGES_CONFIG>,
-    | 'kafka'
-    | 'handlerSpy'
-    | 'autocreateTopics'
-    | 'handlers'
-    | 'connectTimeout'
-    | 'headerRequestIdField'
+    'kafka' | 'handlerSpy' | 'autocreateTopics' | 'handlers' | 'headerRequestIdField'
   >
 >
 
@@ -73,7 +68,6 @@ export class PermissionConsumer extends AbstractKafkaConsumer<
           )
           .build(),
       autocreateTopics: options.autocreateTopics ?? true,
-      clientId: randomUUID(),
       groupId: randomUUID(),
       kafka: options.kafka ?? getKafkaConfig(),
       logMessages: true,