kafkajs - npm Package Versions

[1.5.0-beta.1] - 2019-01-17

Fixed

• Rolling upgrade from 0.10 to 0.11 causes unknown magic byte errors #246

Changed

• Validate consumer groupId #244

Added

• Expose network queue size event to consumers, producers and admin #245

[1.4.7] - 2019-01-17

Fixed

• Rolling upgrade from 0.10 to 0.11 causes unknown magic byte errors #246

[1.5.0-beta.0] - 2019-01-08

Changed

• Add transactional attributes to record batch #199
• Ignore control records #208
• Filter aborted messages on the consumer #223 #210 #228
• Make Round robin assigner forward userdata #231

Added

• Protocol FindCoordinator v1 #189
• Protocol InitProducerId v0 #190
• Protocol AddPartitionsToTxn v0 #191
• Protocol AddOffsetsToTxn v0 #194
• Protocol TxnOffCommit v0 #195
• Protocol EndTxn v0 #198
• Protocol ListOffsets v1 and v2 #217 #209
• Accept max in-flight requests on the connection #216
• Idempotent producer #203
• Transactional producer #206
• Protocol SASLAuthenticate #229
• Add SendOffsets to consumer eachBatch #232
• Add network instrumentation events #233
• Allow users to provide offsets to the commitOffsetsIfNecessary #235

[1.4.6] - 2018-12-03

Fixed

• Always assign partitions based on subscribed topics #227

[1.4.5] - 2018-11-28

Fixed

• Fix crash in mitigation for receiving metadata for unsubscribed topics #221

Added

• Add CRASH instrumentation event for the consumer #221

[1.4.4] - 2018-10-29

Fixed

• Protocol produce v3 wasn't filtering undefined timestamps and was sending timestamp 0 (NaN converted) for all messages #188

[1.4.3] - 2018-10-22

Changed

• Version 1.4.2 without test files

[1.4.2] - 2018-10-22

Changed

• Allow messages with a value of null to support tombstones #185

[1.4.1] - 2018-10-17

Fixed

• Decode multiple RecordBatch on protocol Fetch v4 #179
• Skip incomplete record batches #182
• Producer with acks=0 never resolve #181

Added

• Runtime flag for displaying buffers in debug output #176
• Add ZSTD to compression codecs and types #157
• Admin get topic metadata #174

Changed

• Add description to lock instances #178

[1.4.0] - 2018-10-09

Fixed

• Potential offset loss when updating offsets for resolved partitions #124
• Refresh metadata on lock timeout #131
• Cleans up stale brokers on metadata refresh #131
• Force metadata refresh on ECONNREFUSED #134
• Handle API version not supported #135
• Handle v0.10 messages on v0.11 Fetch API #143

Added

• Admin delete topics #117
• Update metadata api and allow to disable auto topic creation #118
• Use highest available API version #135 #146
• Admin describe and alter configs #138
• Validate message format in producer #142
• Consumers can detect that a topic was updated and force a rebalance #136

Changed

• Improved stack trace for KafkaJSNumberOfRetriesExceeded #123
• Enable Kafka v0.11 API by default #141 (Can still be disabled with allowExperimentalV011=false)
• Replace event emitter Lock #154
• Add member assignment to GROUP_JOIN instrumentation event #136