New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

kafka-node

Package Overview
Dependencies
Maintainers
3
Versions
113
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

kafka-node - npm Package Versions

1245
…
12

2.2.3

Diff
hyperlink
 published 2.2.3 •

Changelog

Source

2017-09-11, Version 2.2.3

  • Improved recovery of ConsumerGroup from broker down and network issues #758
  • Upgrade to snappy 3 #760

2.2.2

Diff
hyperlink
 published 2.2.2 •

Changelog

Source

2017-08-31, Version 2.2.2

  • 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 •

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 •

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 •

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 •

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 •

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 •

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 •

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 •

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
1245
…
12