feat: expose clear metadata

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`.

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
               }
 

src/clients/base/index.ts

@@ -1,7 +1,6 @@
 export {
   Base,
   kCheckNotClosed,
-  kClearMetadata,
   kGetApi,
   kGetBootstrapConnection,
   kGetConnection,

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

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,