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',
 };