From cb314d406a04ce8e85a7556004c03b9707daa137 Mon Sep 17 00:00:00 2001
From: vlzh <vlzh@pm.me>
Date: Fri, 23 Jan 2026 17:29:48 +0600
Subject: [PATCH] Fix CompressionTypes.Snappy naming for KafkaJS compatibility

Rename SNAPPY to Snappy to match the original KafkaJS API naming
convention, ensuring backward compatibility for users migrating
from kafkajs. Also fixes mismatch between TypeScript types and
JavaScript implementation.
---
 lib/kafkajs/_common.js   | 2 +-
 lib/kafkajs/_producer.js | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/kafkajs/_common.js b/lib/kafkajs/_common.js
index 9519265f..ee3d69bf 100644
--- a/lib/kafkajs/_common.js
+++ b/lib/kafkajs/_common.js
@@ -244,7 +244,7 @@ const CompatibilityErrorMessages = Object.freeze({
   sendOptionsAcks: (fn) =>
     createReplacementErrorMessage('producer', fn, 'acks', 'acks: <number>', 'acks: <number>', false),
   sendOptionsCompression: (fn) =>
-    createReplacementErrorMessage('producer', fn, 'compression', 'compression: <type>', 'compression: CompressionTypes.GZIP|SNAPPY|LZ4|ZSTD', false),
+    createReplacementErrorMessage('producer', fn, 'compression', 'compression: <type>', 'compression: CompressionTypes.GZIP|Snappy|LZ4|ZSTD', false),
   sendOptionsTimeout: (fn) =>
     createReplacementErrorMessage('producer', fn, 'timeout', 'timeout: <number>', 'timeout: <number>', false),
   sendBatchMandatoryMissing: () =>
diff --git a/lib/kafkajs/_producer.js b/lib/kafkajs/_producer.js
index 2d780afe..c16586f6 100644
--- a/lib/kafkajs/_producer.js
+++ b/lib/kafkajs/_producer.js
@@ -34,7 +34,7 @@ const ProducerState = Object.freeze({
 const CompressionTypes = {
   None: 'none',
   GZIP: 'gzip',
-  SNAPPY: 'snappy',
+  Snappy: 'snappy',
   LZ4: 'lz4',
   ZSTD: 'zstd',
 };