Module kflow_kafka_consumer

kflow_kafka_consumer is a source type that reads data from Kafka (using legacy single-threaded behavior).

Copyright © 2019 Klarna Bank AB (publ)

Description

kflow_kafka_consumer is a source type that reads data from Kafka (using legacy single-threaded behavior).

Data Types

config()

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}

Function Index

handle_message/4
init/2
start_link/1
stop/1

Function Details

handle_message/4

handle_message(Topic, Partition, MessageSet, State0) -> any()

init/2

init(GroupId, Config) -> any()

start_link/1

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

stop/1

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


Generated by EDoc