Packages

erlkaf

2.2.0
2.2.1 2.2.0 2.1.9 2.1.8 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.9 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3

erlkaf - Erlang Kafka library based on librdkafka

HexDocs

Current section

Files

Jump to
Readme
30 Versions
2 Dependencies
Dependants
Files
Activity
erlkaf src erlkaf_consumer_callbacks.erl
Raw

src/erlkaf_consumer_callbacks.erl 

-module(erlkaf_consumer_callbacks).



-include("erlkaf.hrl").



-callback init(binary(), integer(), integer(), any()) ->

    {ok, any()}.



-callback handle_message(#erlkaf_msg{}, state()) ->

    {ok, state()} | {error, reason(), state()}.



-callback handle_failed_message(#erlkaf_msg{}, state()) ->

    {ok, state()}.



-callback stats_callback(client_id(), map()) ->

    ok.



-callback oauthbearer_token_refresh_callback(binary()) ->

    ok.



-optional_callbacks([

    stats_callback/2,

    handle_failed_message/2,

    oauthbearer_token_refresh_callback/1

]).