Module kflow_produce_to_kafka

This module publishes message sets to a Kafka topic.

Copyright © 2019 Klarna Bank AB (publ)

Description

This module publishes message sets to a Kafka topic. partition key determines what partition the message set will be produced to.

Input message format:
   #{ values => [ #{ key => K1
                   , value => V1
                   , headers => H1
                   }
                , #{ key => K2
                   , value => V2
                   , headers => H2
                   }
                , ...
                ]
    , partition => Partition
    }

Output message format:

Messages are returned as is.

Example usage

    {map, kflow_produce_to_kafka, #{ topic  => <<"downstream_topic">> % Mandatory
                                   , client => ?kflow_default_client
                                   }}

Data Types

config()

config() = #{topic := brod:topic(), client => atom()}


Generated by EDoc