quintoandar-kafka
v0.2.6
Published
Default Kafka NodeJS lib for QuintoAndar
Downloads
15
Maintainers
Keywords
Readme
Node Kafka
Standard node consumer/producer implementation for QuintoAndar.
Consumer Caracteristics
- Commits offset to Kafka after message is processed.
- Node processes messages asynchronously, so there is no guarantee that messages with errors will be reprocessed. This should be done at aplication level.
- Has an optional custom implementation to make message processing idempotent.
- Is resilient to cluster node failures.
- The handleMessageFn is exepected to return a promisse. The promisse should be resolved after the message is processed, this will trigger the offset commit in Kafka.
Examples
See examples folder
Configuration
Checkout kafka-node repo for configuration info.