# genstage_kafka
A GenStage consumer, that will sink its events into a Kafka producer

## Example of use

In a GenStage chain, you can start this module as you would a "normal" GenStage
consumer by use of the GenStageKafka.start_link(kafkaOptions)

The kafkaOptions currently handled are (with defaults given):

  :hosts - [localhost: 9092]
  :topics - "no_topic"
  :partition - 0

## Installation

If [available in Hex](, the package can be installed
by adding `genstage_kafka` to your list of dependencies in `mix.exs`:

def deps do
  [{:genstage_kafka, "~> 0.1.0"}]

Documentation can be generated with [ExDoc](
and published on [HexDocs]( Once published, the docs can
be found at [](