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.