Module kflow_wf_chunks_to_local_file

This workflow assembles chunked transmissions into local files.

Description

This workflow assembles chunked transmissions into local files.

config() = #{kafka_client => atom(), consumer_config => proplists:proplist(), kafka_topic := brod:topic(), group_id := brod:group_id(), location := file:filename_all(), filter => predicate()}

predicate() = fun((Key::binary()) -> boolean())

Create a workflow specification.

workflow(Id::atom(), Config::config()) -> kflow:workflow()

Create a workflow specification

Generated by EDoc