Fix regression when calling consumer's setOffset fails to set the given offset #457
Improved zookeeeper connection loss recovery to verify consumer is still registered #458

0.5.6

Diff

hyperlink

published 0.5.6 • 8 years ago

Changelog

Source

2016-08-17, Version 0.5.6

Fix older version of node issue introduced in last version #447

0.5.5

Diff

hyperlink

published 0.5.5 • 8 years ago

Changelog

Source

2016-08-11, Version 0.5.5

Updated doc #443
Validate topic's partition value to be a number #442
Fixed issue where module was relying on deprecated kafka configs (especially broken when SSL is enabled) #427

0.5.4

Diff

hyperlink

published 0.5.4 • 8 years ago

Changelog

Source

2016-08-09, Version 0.5.4

Fix lost client options when creating a Client w/o the new operator #437
Fix issue rebalances can be missed when an event occurs during rebalance #435
Fix issue where changes to a topic's number of partitions should trigger a rebalance #430
Added coverall coverage and additional tests #433 and #432

0.5.3

Diff

hyperlink

published 0.5.3 • 8 years ago

Changelog

Source

2016-08-05, Version 0.5.3

Fix for some long standing high-level consumer rebalance issues: #423
- Fixed issue where consumers who weren't assigned a partition would never rebalance... ever
- Fixed issue where calling close consumer did not force the consumer to leave the consumer group and so locks the partition(s) for (the default) of 30000ms
- Fixed issue where consumers who weren't assigned a partition never emitted a rebalance event after rebalancing
- Additional cases to be addressed in the next release:
  - If consumer joins or leaves a group during another consumers rebalance then that rebalancing consumer may miss owning partitions
  - Changes to a topic's partition does not trigger a rebalance
Update doc to warn about possible data loss with way the data is formated when sending with the producer #425
Added code coverage and additional high-level producer tests #422

0.5.2

Diff

hyperlink

published 0.5.2 • 8 years ago

Changelog

Source

2016-07-29, Version 0.5.2

Fix TypeError: Cannot read property 'sslHost' of undefined #417

0.5.1

Diff

hyperlink

published 0.5.1 • 8 years ago

Changelog

Source

2016-07-27, Version 0.5.1

Prevent fetch before offset's are updated before a rebalance #402
Add validation to groupId and clientId #405
Removed unused autoCommitMsgCount config option #406
Fixed issue where reconnecting brokers emits a connect event instead of reconnect. #413
Fixed uncaught exception where sslHost or host of undefined is accessed. #413

0.5.0

Diff

hyperlink

published 0.5.0 • 8 years ago

Changelog

Source

2016-07-14, Version 0.5.0

Fix minimatch vulnerability by upgrading snappy to v5.0.5 #400
Added ESLint to codebase #392
Added ability to make SSL connections to brokers #383 (Kafka 0.9+ only)

0.4.0

Diff

hyperlink

published 0.4.0 • 8 years ago

Changelog

Source

2016-06-27, Version 0.4.0

Update test to run against docker #387
Fix missing npm license field warning #386
Recreate broker sockets to work around nodejs socket issue #4417 #385
Fixes #319 UnknownTopicOrPartition error when reassigning topic #384
Add offset#getLatestOffsets function to get all the latest offsets from a group of topics populating those topics partitions #372

0.3.3

Diff

hyperlink

published 0.3.3 • 9 years ago

Changelog

Source

2016-05-27, Version 0.3.3

Fix type error while producing messages #360
Update README #307 and #352
Add contributing guidelines #346
Make Snappy an optional dependency #347

…

kafka-node - npm Package Versions

0.5.7

.css-1z04cui{margin-bottom:var(--chakra-space-4);font-size:var(--chakra-fontSizes-md);}2016-09-07, Version 0.5.7

0.5.6

2016-08-17, Version 0.5.6

0.5.5

2016-08-11, Version 0.5.5

0.5.4

2016-08-09, Version 0.5.4

0.5.3

2016-08-05, Version 0.5.3

0.5.2

2016-07-29, Version 0.5.2

0.5.1

2016-07-27, Version 0.5.1

0.5.0

2016-07-14, Version 0.5.0

0.4.0

2016-06-27, Version 0.4.0

0.3.3

2016-05-27, Version 0.3.3

2016-09-07, Version 0.5.7