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.

Checkout kafka-node repo for configuration info.