Remove debug-only properties

Author: milindl

lib/kafkajs/_consumer.js

@@ -176,12 +176,6 @@ class Consumer {
    */
   #topicPartitionToBatchPayload = new Map();
 
-  /**
-   * TODO: remove this or make it a bit more reliable.
-   * This is a debug property for this branch.
-   */
-  clientId = null;
-
   /**
    * @constructor
    * @param {import("../../types/kafkajs").ConsumerConfig} kJSConfig
@@ -390,7 +384,7 @@ class Consumer {
         { code: error.ErrorCodes.ERR__INVALID_ARG });
     }
     const rdKafkaConfig = kafkaJSToRdKafkaConfig(kjsConfig);
-    this.clientId = rdKafkaConfig['client.id'];
+
     this.#logger = new DefaultLogger();
 
     /* Consumer specific configuration */
@@ -1190,7 +1184,7 @@ class Consumer {
    *
    * Worker termination acts as a async barrier.
    */
-  async #worker(config, perMessageProcessor, fetcher, id) {
+  async #worker(config, perMessageProcessor, fetcher) {
     let nextIdx = -1;
     while (!this.#workerTerminationScheduled) {
       /* Invalidate the message cache if needed */
@@ -1252,7 +1246,7 @@ class Consumer {
         Array(workersToSpawn)
           .fill()
           .map((_, i) =>
-            this.#worker(config, perMessageProcessor.bind(this), fetcher.bind(this), i)
+            this.#worker(config, perMessageProcessor.bind(this), fetcher.bind(this))
               .catch(e => {
                 if (this.#logger)
                   this.#logger.error(`Worker ${i} encountered an error: ${e}:${e.stack}`);