kafka-node - npm Package Versions

2018-09-11, Version 3.0.1

• Fixed issue with new topic/partition detection when topic contains dots #1076
• Using double ended queue for message buffer in ConsumerGroupStream and ConsumerStream #1067
• Fixed issue in ConsumerGroupStream where forcing a commit breaks auto commit. #1066

2018-09-05, Version 3.0.0

• Added TS definitions #959 #965 #1022 #965 #1049 #965
• Fixed issue where ConsumerGroup refresh metadata errors weren't being correctly emitted as 'error' #971
• Fixed issue where HighLevelConsumer throw FailedToRebalanceConsumerError: NODE_EXISTS when rebalancing #981
• Fixed Admin.listGroups error handling #985
• Added support to create topics (specifying partitions and replication) using the Admin API (supported in Kafka v0.10 only) #958
• Updated client to remove unnecessary zookeeper reconnect #1011
• Remove noisy debug logs #1009 #1033
• Added SASL/PLAIN Authentication #923 #1033
• Fixed issue where closing a client can still refreshBrokerMetadata #1048
• Fixed empty messages caused by decoding partial messages from 2.0 broker #1050
• Fix consumerGroup removeTopics not able to remove topics #1012
• Added more descriptive errors as to why broker is not available #1023
• Fix Admin API describe groups error handling #1010
• ConsumerGroup leader will now monitors metadata for new topics/partitions. Once change has been detected it will leave and join the group to trigger a rebalance. This interval is controlled by topicPartitionCheckInterval option (defaults to every 30 seconds) #1057

BREAKING CHANGES

• Dropped support for node 4
• KafkaClient createTopics method drops the second async parameter since it uses the Admin API to create Topics

2018-04-27, Version 2.6.1

• Fix issue where duplicate messages are received when connecting to multiple brokers (restored dedicated consumer socket) #956

2018-04-24, Version 2.6.0

• Fix issue during the initial connection phase can end prematurely when metadata request failed #920
• Add addTopics method to the ConsumerGroup #914
• Fix issue where yielding a result in onRebalance in ConsumerGroup leads to an exception being thrown #922
• Add support for Kafka Fetch versions 1 and 2 this enables produced timestamps to be read from the Consumer (Kafka 0.10+). Fetches also now share socket to the broker with other kafka requests (previously fetches were on a dedicated socket) #871
• Add support to auto commit on first join ConsumerGroup configured using commitOffsetsOnFirstJoin #897
• Add support for Buffers as keys, which is useful for Avro encoded keys #932

2018-04-09, Version 2.5.0

• Explicitly cast key to string in hashCode function for KeyedPartitioner #870
• For consumer fetch loop we now clear socket.waiting before invoking callbacks #819
• Add Support for IPv6 #818
• Clear internal topicPayload array if no topic partitions are assigned to the ConsumerGroup #888
• Fix Stale Commit Queue for ConsumerGroupStream #891
• For rebalance case ConsumerGroup will try to commit before joining a group. Added onRebalance callback for manual commit users #889

2018-02-06, Version 2.4.1

• Fix issue where error callbacks for broker requests are not called when connection is closed #863

2018-02-06, Version 2.4.0

• Add compability to Client with broker configurations that separates external and internal traffic #860
• Fix issue where updateMetadata() wipes out entire topic metadata when only updating specific topics #857

2018-01-16, Version 2.3.2

• Fix issue with ConsumerGroupStream where lag stays at one and resuming the consumer re-reads the last read message #850

2018-01-7, Version 2.3.1

• Fix consumer example #842
• Fix issue where ConsumerGroupStream will autoCommit when the stream is explicitly closed #843
• Fix missing highWaterOffset using compression #821
• Fix Snappy buffer.from error using node 4 #827
• Fix fromOffset option not working in ConsumerStream #794
• Fixed issue where producer send failures failed to request refresh of the metadata #810

2017-11-17, Version 2.3.0

• Add support for ListGroups and DescribeGroups protocol. They can be used through the new Admin interface #770
• Fixed missing callback call in commit method of ConsumerGroupStream #776
• Flush queued commits of ConsumerGroupStream on tail end of auto-commit time-out #775