franz

-module(franz@consumer_config).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export_type([consumer_config/0, offset_time/0, offset_reset_policy/0]).

-type consumer_config() :: {begin_offset, offset_time()} |
    {min_bytes, integer()} |
    {max_bytes, integer()} |
    {max_wait_time, integer()} |
    {sleep_timeout, integer()} |
    {prefetch_count, integer()} |
    {prefetch_bytes, integer()} |
    {offset_reset_policy, offset_reset_policy()} |
    {size_stat_window, integer()} |
    {isolation_level, franz@isolation_level:isolation_level()} |
    {share_leader_conn, boolean()}.

-type offset_time() :: latest | earliest | {message_timestamp, integer()}.

-type offset_reset_policy() :: reset_by_subscriber |
    reset_to_earliest |
    reset_to_latest.