switch kafka-lz4-lite

Author: arcoraven

packages/service-utils/package.json

@@ -46,8 +46,8 @@
   "sideEffects": false,
   "dependencies": {
     "aws4fetch": "1.0.20",
+    "kafka-lz4-lite": "^1.0.5",
     "kafkajs": "2.2.4",
-    "kafkajs-lz4": "2.0.0-beta.0",
     "zod": "3.24.1"
   },
   "devDependencies": {

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

@@ -1,12 +1,12 @@
 import { randomUUID } from "node:crypto";
 import { checkServerIdentity } from "node:tls";
+import { codec as lz4Codec } from "kafka-lz4-lite";
 import {
   CompressionTypes,
   Kafka,
   type Producer,
   type ProducerConfig,
 } from "kafkajs";
-import LZ4Codec from "kafkajs-lz4";
 import type { ServiceName } from "../core/services.js";
 import { type UsageV2Event, getTopicName } from "../core/usageV2.js";
 
@@ -91,7 +91,7 @@ export class UsageV2Producer {
    */
   async init(configOverrides?: ProducerConfig) {
     if (this.compression === CompressionTypes.LZ4) {
-      CompressionCodecs[CompressionTypes.LZ4] = new LZ4Codec().codec;
+      CompressionCodecs[CompressionTypes.LZ4] = lz4Codec;
     }
 
     this.producer = this.kafka.producer({