From 348effc079e1b32cd28596b24abd7ffc76df7d2c Mon Sep 17 00:00:00 2001
From: Simone Sanfratello <simone.sanfra@gmail.com>
Date: Mon, 10 Nov 2025 13:00:23 +0100
Subject: [PATCH 1/2] feat: expose clear metadata

---
 docs/base.md                     | 4 ++++
 src/clients/base/base.ts         | 7 +++----
 src/clients/base/index.ts        | 1 -
 src/clients/consumer/consumer.ts | 3 +--
 src/clients/producer/producer.ts | 3 +--
 5 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/docs/base.md b/docs/base.md
index 3fbf387..4f5b212 100644
--- a/docs/base.md
+++ b/docs/base.md
@@ -79,6 +79,10 @@ Returns `true` if the client is not closed.
 
 Returns `true` if all client's connections are currently connected and the client is connected to at least one broker.
 
+### `clearMetadata`
+
+Clear the current metadata.
+
 ## Connecting to Kafka via TLS connection
 
 To connect to a Kafka via TLS connection, simply pass all relevant options in the `tls` options when creating any subclass of `Base`.
diff --git a/src/clients/base/base.ts b/src/clients/base/base.ts
index 9e04b50..42bc8c3 100644
--- a/src/clients/base/base.ts
+++ b/src/clients/base/base.ts
@@ -53,7 +53,6 @@ export const kClosed = Symbol('plt.kafka.base.closed')
 export const kListApis = Symbol('plt.kafka.base.listApis')
 export const kMetadata = Symbol('plt.kafka.base.metadata')
 export const kCheckNotClosed = Symbol('plt.kafka.base.checkNotClosed')
-export const kClearMetadata = Symbol('plt.kafka.base.clearMetadata')
 export const kPerformWithRetry = Symbol('plt.kafka.base.performWithRetry')
 export const kPerformDeduplicated = Symbol('plt.kafka.base.performDeduplicated')
 export const kValidateOptions = Symbol('plt.kafka.base.validateOptions')
@@ -339,7 +338,7 @@ export class Base<OptionsType extends BaseOptions = BaseOptions> extends EventEm
     return false
   }
 
-  [kClearMetadata] (): void {
+  clearMetadata (): void {
     this.#metadata = undefined
   }
 
@@ -576,7 +575,7 @@ export class Base<OptionsType extends BaseOptions = BaseOptions> extends EventEm
 
               // Stale metadata, we need to fetch everything again
               if (hasStaleMetadata) {
-                this[kClearMetadata]()
+                this.clearMetadata()
                 topicsToFetch = options.topics
               }
 
@@ -650,4 +649,4 @@ export class Base<OptionsType extends BaseOptions = BaseOptions> extends EventEm
       })
     }
   }
-}
+}
\ No newline at end of file
diff --git a/src/clients/base/index.ts b/src/clients/base/index.ts
index 852dc7e..fa9602a 100644
--- a/src/clients/base/index.ts
+++ b/src/clients/base/index.ts
@@ -1,7 +1,6 @@
 export {
   Base,
   kCheckNotClosed,
-  kClearMetadata,
   kGetApi,
   kGetBootstrapConnection,
   kGetConnection,
diff --git a/src/clients/consumer/consumer.ts b/src/clients/consumer/consumer.ts
index 4fd7bf8..6fd0e48 100644
--- a/src/clients/consumer/consumer.ts
+++ b/src/clients/consumer/consumer.ts
@@ -61,7 +61,6 @@ import {
   Base,
   kAfterCreate,
   kCheckNotClosed,
-  kClearMetadata,
   kClosed,
   kCreateConnectionPool,
   kFetchConnections,
@@ -1909,7 +1908,7 @@ export class Consumer<Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderVa
 
   #handleMetadataError (error: Error | null): Error | null {
     if (error && (error as GenericError)?.findBy('hasStaleMetadata', true)) {
-      this[kClearMetadata]()
+      this.clearMetadata()
     }
 
     return error
diff --git a/src/clients/producer/producer.ts b/src/clients/producer/producer.ts
index a4b2151..af34d0c 100644
--- a/src/clients/producer/producer.ts
+++ b/src/clients/producer/producer.ts
@@ -16,7 +16,6 @@ import {
   Base,
   kAfterCreate,
   kCheckNotClosed,
-  kClearMetadata,
   kClosed,
   kGetApi,
   kGetBootstrapConnection,
@@ -515,7 +514,7 @@ export class Producer<Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderVa
             const hasStaleMetadata = (error as GenericError).findBy('hasStaleMetadata', true)
 
             if (hasStaleMetadata && repeatOnStaleMetadata) {
-              this[kClearMetadata]()
+              this.clearMetadata()
               this.#performSingleDestinationSend(
                 topics,
                 messages,

From c2d09b958f4f01ab4c5e35cb1c30cfc33ab84d23 Mon Sep 17 00:00:00 2001
From: Simone Sanfratello <simone.sanfra@gmail.com>
Date: Mon, 10 Nov 2025 13:33:53 +0100
Subject: [PATCH 2/2] fix: lint

---
 src/clients/base/base.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/clients/base/base.ts b/src/clients/base/base.ts
index 42bc8c3..ba2e4ac 100644
--- a/src/clients/base/base.ts
+++ b/src/clients/base/base.ts
@@ -649,4 +649,4 @@ export class Base<OptionsType extends BaseOptions = BaseOptions> extends EventEm
       })
     }
   }
-}
\ No newline at end of file
+}