Fix issue where connections disconnected from being idle will never reinitialize when using KafkaClient #752
Fix callback of producer send never being called when connection loss occurs with Broker using KafkaClient #751

2.2.1

Diff

hyperlink

published 2.2.1 • 7 years ago

Changelog

Source

2017-08-21, Version 2.2.1

Fix duplicate messages emitted when using KafkaClient and consuming topic/partition that span multiple brokers #747
Instead of failing silently consumers now emits a error when trying to consume messages that exceeds fetchMaxBytes #744

2.2.0

Diff

hyperlink

published 2.2.0 • 7 years ago

Changelog

Source

2017-08-08, Version 2.2.0

Fix decoding of messages produced using KafkaClient with timestamps #736
Add Writable stream ProducerStream #734

2.1.0

Diff

hyperlink

published 2.1.0 • 7 years ago

Changelog

Source

2017-08-03, Version 2.1.0

Add two Readable streams ConsumerGroupStream and ConsumerStream #732
Add V1 and V2 Produce request (adds client timestamps) to KafkaClient only supported in kafka v0.9 and v0.10 #730

2.0.1

Diff

hyperlink

published 2.0.1 • 7 years ago

Changelog

Source

2017-07-13, Version 2.0.1

Fix unreferenced method call in Client/KafkaClient #708

2.0.0

Diff

hyperlink

published 2.0.0 • 7 years ago

Changelog

Source

2017-07-08, Version 2.0.0

Fix out of range error causing idle consumers to crash. This was a performance improvement made in 1.6.1 and reverted in 1.6.2 #672
Add KafkaClient a version of Client that connects directly to Kafka brokers instead of zookeeper for discovery. #691

1.6.2

Diff

hyperlink

published 1.6.2 • 8 years ago

Changelog

Source

2017-05-08, Version 1.6.2

Reverting performance changes using BufferList since it's causing idle consumers to crash #670

1.6.1

Diff

hyperlink

published 1.6.1 • 8 years ago

Changelog

Source

2017-05-04, Version 1.6.1

Fix Offset calling .fetchOffset methods not yielding callback when the topic does not exist #662
Improved performance of Client using BufferList instead of Buffer.slice #654

1.6.0

Diff

hyperlink

published 1.6.0 • 8 years ago

Changelog

Source

2017-03-16, Version 1.6.0

Add ability to provide your own custom partitioner implementation (see docs for Producer) #625
Create topics will yield with topics created #618

…

kafka-node - npm Package Versions

2.2.3

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

2.2.2

2017-08-31, Version 2.2.2

2.2.1

2017-08-21, Version 2.2.1

2.2.0

2017-08-08, Version 2.2.0

2.1.0

2017-08-03, Version 2.1.0

2.0.1

2017-07-13, Version 2.0.1

2.0.0

2017-07-08, Version 2.0.0

1.6.2

2017-05-08, Version 1.6.2

1.6.1

2017-05-04, Version 1.6.1

1.6.0

2017-03-16, Version 1.6.0

2017-09-11, Version 2.2.3