-module(franz@consumer_config). -compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]). -define(FILEPATH, "src/franz/consumer_config.gleam"). -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.