kflow_kafka_consumer
is a source type that reads data from
Kafka (using legacy single-threaded behavior).
Copyright © 2019 Klarna Bank AB (publ)
kflow_kafka_consumer
is a source type that reads data from
Kafka (using legacy single-threaded behavior).
config() = #{brod_client_id => atom(), group_id := brod:group_id(), topics := [brod:topic()], id := atom(), pipe_spec := kflow:pipe() | fun((kflow:node_spec()) -> kflow:pipe()), auto_commit => boolean(), consumer_config => brod:consumer_config(), feed_timeout => timeout(), shutdown_timeout => timeout(), flush_interval => non_neg_integer() | undefined}
handle_message/4 | |
init/2 | |
start_link/1 | |
stop/1 |
handle_message(Topic, Partition, MessageSet, State0) -> any()
init(GroupId, Config) -> any()
start_link(Config::config()) -> {ok, pid()}
stop(Pid::pid()) -> ok
Generated by EDoc