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

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"}]
end

Documentation can be generated with ExDoc and published on HexDocs. Once published, the docs can be found at https://hexdocs.pm/kafka_genstage.