Skip to content

Commit 5688a95

Browse files
committed
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.
1 parent 2fef45b commit 5688a95

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

lib/kafkajs/_producer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ const ProducerState = Object.freeze({
3434
const CompressionTypes = {
3535
None: 'none',
3636
GZIP: 'gzip',
37-
SNAPPY: 'snappy',
37+
Snappy: 'snappy',
3838
LZ4: 'lz4',
3939
ZSTD: 'zstd',
4040
};

0 commit comments

Comments
 (0)