0.11.0 • Published 12 months ago

@sensejs/kafkajs-standalone v0.11.0

Weekly downloads
22
License
ISC
Repository
-
Last release
12 months ago

Standalone Wrapper for KafkaJS

This package provides easy to use kafka consumer and producer based on kafkajs, without core parts of sense.js as dependencies.

Install

npm install @sensejs/kafkajs-standalone kafkajs

Highlights:

  • Consumer:

    1. Automatically set partitionConsumedConcurrently to number of partitions of a topic, to maximum the throughput.

    2. Detect rebalance as quickly as possible.

    3. Save offset when consumer group is going to rebalance, to avoid any message be re-consumed as possible as it can (while still you should not expect it won't happen).

  • Producer:

    1. Default maxInFlightRequests to 1 and idempotent to true, to fit requirements of transactional producer. Can be overridden if transaction is not required.

    2. Ability to provide messageKeyProvider to assign a key to message if not specified.

0.11.0

12 months ago

0.10.1

12 months ago

0.10.0

1 year ago

0.11.0-alpha.0

12 months ago

0.11.0-alpha.1

12 months ago

0.10.0-alpha.0

1 year ago

0.9.3

2 years ago

0.9.2

2 years ago

0.9.0

2 years ago

0.9.1

2 years ago

0.9.0-alpha.6

2 years ago

0.9.0-alpha.5

2 years ago

0.9.0-alpha.4

3 years ago

0.9.0-alpha.2

3 years ago

0.9.0-alpha.3

3 years ago

0.9.0-alpha.1

3 years ago

0.9.0-alpha.0

3 years ago

0.8.3

3 years ago

0.8.2

3 years ago

0.8.1

3 years ago

0.8.0

3 years ago

0.8.0-alpha.4

3 years ago

0.7.1

3 years ago

0.8.0-alpha.3

3 years ago

0.8.0-alpha.2

3 years ago

0.8.0-alpha.1

3 years ago

0.7.0

4 years ago

0.6.1

4 years ago

0.6.0

4 years ago

0.5.2

4 years ago

0.5.1

4 years ago

0.5.0

4 years ago

0.4.2

4 years ago

0.4.1

4 years ago

0.4.0

4 years ago

0.3.6

4 years ago

0.3.5

4 years ago

0.3.4

4 years ago

0.3.3

4 years ago

0.3.1

4 years ago

0.3.0

4 years ago

0.3.0-0

4 years ago

0.2.1

4 years ago

0.2.0

4 years ago

0.2.0-0

4 years ago