QuintoAndar's kafka-python lib wrapper with additional functionalities.
A simple wrapper for kafka-python lib that uses redis to check duplicate events.
| Name | Description |
|---|---|
| group_id | The consumer group id |
| bootstrap_servers | The bootstrap servers |
| redis_host | The topic to consume from |
| redis_port | The function that processes the event |
| idempotent_key | Function which extract an unique identifier from the event |
See examples