Module kflow_produce_to_kafka

Description
Data Types

This module publishes message sets to a Kafka topic.

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