[2.0.0] - 2022-05-06

⚠️ This is the first major version released in 4 years, and contains a few important breaking changes. A migration guide has been prepared to help with the migration process. Be sure to read it before upgrading from older versions of KafkaJS.

Big thanks to @priitkaard for contributing some amazing performance improvements included in this release! Expect to see higher throughput and more efficient resource utilization compared to previous versions, especially in scenarios where you have an uneven distribution of messages across partitions.

Added

• Validate configEntries when creating topics #1309
• New topics argument for consumer.subscribe to subscribe to multiple topics #1313
• Support duplicate header keys #1132

Removed

• BREAKING: Drop support for Node 10 and 12 #1333
• BREAKING: Remove deprecated enum ResourceTypes #1334
• BREAKING: Remove deprecated argument topic from admin.fetchOffsets #1335
• BREAKING: Remove deprecated method getTopicMetadata from admin client #1336
• BREAKING: Remove typo type TopicPartitionOffsetAndMedata #1338
• BREAKING: Remove deprecated error property originalError. Replaced by cause #1341

Changed

• BREAKING: Change default partitioner to Java compatible #1339
• Improve consumer performance #1258
• BREAKING: Enforce request timeout by default #1337
• Honor default replication factor and partition count when creating topics #1305
• Increase default authentication timeout to 10 seconds #1340

Fixed

• Fix invalid sequence numbers when producing concurrently with idempotent producer #1050 #1172
• Fix correlation id and sequence number overflow #1310
• Fix consumer not restarting on retriable connection errors #1304
• Avoid endless sleep loop #1323