Copyright © 2019 Klarna Bank AB (publ)
config() = #{kafka_client => atom(), consumer_config => proplists:proplist(), kafka_topic := brod:topic(), group_id := brod:group_id(), s3_bucket := file:filename_all(), prefix => string() | binary(), filter => predicate()}
predicate() = fun((Key::binary()) -> boolean())
workflow/2 | Create a workflow specification. |
workflow(Id::atom(), Config::config()) -> kflow:workflow()
Create a workflow specification
Generated by EDoc