move codec to init

Author: arcoraven

packages/service-utils/src/node/usageV2.ts

@@ -80,16 +80,17 @@ export class UsageV2Producer {
 
     this.topic = getTopicName(productName);
     this.compression = compression;
-    if (compression === CompressionTypes.LZ4) {
-      CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;
-    }
   }
 
   /**
    * Connect the producer.
    * This must be called before calling `sendEvents()`.
    */
   async init(configOverrides?: ProducerConfig) {
+    if (this.compression === CompressionTypes.LZ4) {
+      CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;
+    }
+
     this.producer = this.kafka.producer({
       allowAutoTopicCreation: false,
       ...configOverrides,