kafkajs - npm Package Versions

[1.10.0] - 2019-07-31

Added

• Allow the consumer to pause and resume individual partitions #417
• Add consumer.commitOffsets for manual committing #436
• Expose consumer paused partitions #444

Changed

• Removed unnecessary async code #434
• Use SubscriptionState to track member assignment #429

Fixed

• Improve type compatibility with @types/kafkajs #416
• Fix fetchTopicMetadata return type #433

[1.9.3] - 2019-06-27

Fixed

• Fix AWS-IAM mechanism name #411 #412
• Fix TypeScript types for topic subscription with RegExp #413

[1.9.2] - 2019-06-26

Fixed

• Fix typescript types for Logger, consumer pause and resume, eachMessage and EachBatch interfaces #409

[1.9.1] - 2019-06-25

Fixed

• Fix typescript types for SSL, SASL and batch #407

[1.9.0] - 2019-06-25

Added

• Add typescript declaration file #362 #385 #390
• Add requestTimeout to apiVersions #369
• Discard messages saw a seek operation during a fetch or batch processing #367
• Include fetched offset metadata retrieved with admin.fetchOffsets #389
• Allow offset metadata to be written as part of OffsetCommit requests #392
• Prevent the consumption of messages for topics paused while fetch is in-flight #397
• Add AWS-IAM SASL mechanism #402
• Add batch.offsetLagLow #405

Changed

• Don't modify global.crypto #365
• Change log level about producer without metadata #382
• Update encoder to write arrays as single Buffer.concat where possible #394

Fixed

• Log error message on connection errors #400
• Make sure runner has connected brokers and fresh metadata before it starts #404

[1.8.1] - 2019-06-25

Fixed

• Make sure runner has connected brokers and fresh metadata before it starts #404