File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -5,6 +5,18 @@ All notable changes to this project will be documented in this file.
55The format is based on [ Keep a Changelog] ( http://keepachangelog.com/en/1.0.0/ )
66and this project adheres to [ Semantic Versioning] ( http://semver.org/spec/v2.0.0.html ) .
77
8+ ## [ 2.1.0] - 2022-06-28
9+
10+ ### Added
11+ - Add ` pause ` function to ` eachMessage ` /` eachBatch ` to pause the current topic-partition #1364
12+ - The ` KafkaMessage ` type is now a union between the pre-Kafka 0.10 message format and the current #1401
13+
14+ ### Fixed
15+ - Fix 100% CPU utilization when all brokers are unavailable #1402
16+ - Fix persistent error when trying to produce after a topic authorization error #1385
17+ - Fix error when aborting or committing an empty transaction #1388
18+ - Don't re-process messages from a paused partition after breaking the consumption flow #1382
19+
820## [ 2.0.2] - 2022-05-31
921
1022### Fixed
Original file line number Diff line number Diff line change 11{
22 "name" : " kafkajs" ,
3- "version" : " 2.0.2 " ,
3+ "version" : " 2.1.0 " ,
44 "description" : " A modern Apache Kafka client for node.js" ,
55 "author" : " Tulio Ornelas <ornelas.tulio@gmail.com>" ,
66 "main" : " index.js" ,
You can’t perform that action at this time.
0 commit comments