Module kflow_kafka_consumer_v2

kflow_kafka_consumer_v2 is a source type that reads data from Kafka.

Description

kflow_kafka_consumer_v2 is a source type that reads data from Kafka

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(MessageSet, State) -> any()

init(InitInfo, Config) -> any()

start_link(Config::config()) -> {ok, pid()}

stop(Pid::pid()) -> ok

terminate(Reason, S) -> any()

Generated by EDoc